Struct ReadonlyReactiveValue

pub struct ReadonlyReactiveValue<T> { /* private fields */ }

Holds the latest value emitted by a stream.

ReactiveValues automatically unsubscribe from the stream when they are destroyed, preventing the kinds of memory leaks common in reactive programming.

Examples

use epoxy_streams::ReactiveValue;

let stream_host: epoxy_streams::Sink<i32> = epoxy_streams::Sink::new();
let stream = stream_host.get_stream();
let reactive_value = stream.map(|val| val * 100).to_reactive_value();
assert_eq!(*reactive_value.get(), 0);
stream_host.emit(1);
assert_eq!(*reactive_value.get(), 100);
stream_host.emit(3);
assert_eq!(*reactive_value.get(), 300);

use epoxy_streams::ReactiveValue;

let stream_host: epoxy_streams::Sink<i32> = epoxy_streams::Sink::new();
let stream = stream_host.get_stream();
let reactive_value = stream.map(|val| val * 100).to_reactive_value_with_default(1000);
assert_eq!(*reactive_value.get(), 1000);
stream_host.emit(100);
assert_eq!(*reactive_value.get(), 10000);

Trait Implementations

impl<T> Clone for ReadonlyReactiveValue<T>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> ReactiveValue<T> for ReadonlyReactiveValue<T>

fn as_stream(&self) -> Stream<T>

Returns a Stream that represents the changing value over time. Use this function to subscribe to changes in the ReactiveValue.ReadonlyReactiveValue

fn get(&self) -> Arc<T>

Returns the current value of the ReactiveValue.