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.