Struct Observer 

pub struct Observer<T, Error = ()>
where
    T: Send + Sync + 'static,
    Error: Send + Sync + 'static,
{
    pub next: Box<dyn Fn(T) + Sync + Send>,
    pub error: Box<dyn Fn(Error) + Sync + Send>,
    pub complete: Box<dyn Fn() + Sync + Send>,
    pub start: Box<dyn ObserverStartFunction<T, Error>>,
}

An Observer is used to receive data from an Observable, and is supplied as an argument to subscribe.

Fields

next: Box<dyn Fn(T) + Sync + Send>

Receives the next value in the sequence.

error: Box<dyn Fn(Error) + Sync + Send>

Receives the sequence error.

complete: Box<dyn Fn() + Sync + Send>

Receives a completion notification.

start: Box<dyn ObserverStartFunction<T, Error>>

Receives the subscription object when subscribe is called.

Trait Implementations

impl<T, Error> AbstractObserver<T, Error> for Observer<T, Error>

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

fn next(&self, value: T)

Receives the next value in the sequence.

fn error(&self, error: Error)

Receives the sequence error.

fn complete(&self)

Receives a completion notification.

fn start(&self, subscription: Arc<Subscription<T, Error>>)

Receives the subscription object when subscribe is called.

impl<T, Error> Default for Observer<T, Error>

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

fn default() -> Self

Returns the “default value” for a type.

impl<T, Error> From<Observer<T, Error>> for BoxedObserver<T, Error>

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

fn from(value: Observer<T, Error>) -> Self

Converts to this type from the input type.