Struct Observer 

pub struct Observer;

The factory of observers (Observer).

Implementations

impl Observer

pub fn create<T: 'static>(on_next: impl Fn(T) + 'static) -> Rc<dyn IObserver<T>>

An observer of values; an error panics (Create(Action<T>)).

pub fn create_with_error<T: 'static>( on_next: impl Fn(T) + 'static, on_error: impl Fn(ObservableError) + 'static, ) -> Rc<dyn IObserver<T>>

An observer of values and errors (Create(Action<T>, Action<Exception>)).

pub fn create_with_completed<T: 'static>( on_next: impl Fn(T) + 'static, on_completed: impl Fn() + 'static, ) -> Rc<dyn IObserver<T>>

An observer of values and the end; an error panics (Create(Action<T>, Action)).

pub fn create_all<T: 'static>( on_next: impl Fn(T) + 'static, on_error: impl Fn(ObservableError) + 'static, on_completed: impl Fn() + 'static, ) -> Rc<dyn IObserver<T>>

An observer of all three notifications (Create(Action<T>, Action<Exception>, Action)).

pub fn to_observer<T: 'static>( handler: impl Fn(Notification<T>) + 'static, ) -> Rc<dyn IObserver<T>>

An observer that hands each notification, as a value, to handler (ToObserver(Action<Notification<T>>)).