Trait Observer 

pub trait Observer<T, E> {
    // Required methods
    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

impl<T: Clone, E: Clone> Observer<T, E> for Subject<T, E>