Trait rx::Observer [−] [src]

pub trait Observer<T, E> {
    fn on_next(&mut self, item: T);
    fn on_completed(self);
    fn on_error(self, error: E);
}

An observer that receives values from an observable.

Required Methods

fn on_next(&mut self, item: T)

Provides the observer with new data.

fn on_completed(self)

Notifies the observer that the provider has finished sending notifications.

fn on_error(self, error: E)

Notifies the observer that the provider experienced an error condition.

Implementors