Struct Observable

pub struct Observable<T, Error = ()>
where
    T: Send + Sync + 'static,
    Error: Send + Sync + 'static,
{ /* private fields */ }

An Observable represents a sequence of values which may be observed.

Implementations

impl<T, Error> Observable<T, Error>

where T: Send + Sync + 'static, Error: Send + Sync + 'static,

pub fn new<F, G>(subscriber: F) -> Self

where F: Fn(SubscriptionObserver<T, Error>) -> G + Send + Sync + 'static, G: Fn() + Send + Sync + 'static,

Constructs an observable given a callback.

pub fn subscribe( &self, observer: impl Into<BoxedObserver<T, Error>>, ) -> Arc<Subscription<T, Error>>

Subscribes to the sequence with an observer.

pub fn map<U, F>( &self, map_fn: impl Fn(T) -> U + Send + Sync + 'static, ) -> Observable<U, Error>

where U: Send + Sync + 'static, F: SubscriberFunction<U, Error>,

Returns a new Observable that performs a map on data from the original.

pub fn filter<F>( &self, filter_fn: impl Fn(T) -> bool + 'static + Send + Sync, ) -> Observable<T, Error>

where T: Clone, F: SubscriberFunction<T, Error>,

Returns a new Observable that filters data specified by the predicate.

Trait Implementations

impl<T, Error> Clone for Observable<T, Error>

where T: Send + Sync + 'static, Error: Send + Sync + 'static,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T, Iterable> From<Iterable> for Observable<T, ()>

where Iterable: IntoIterator<Item = T> + Send + Sync, T: Clone + Send + Sync + 'static,

fn from(value: Iterable) -> Self

Constructs an Observable from a list of values.