Struct ObserverBase 

pub struct ObserverBase<T> { /* private fields */ }

An observer that enforces the grammar of the notifications on its core (ObserverBase<T>): values reach the core until a terminal notification; the first terminal notification reaches it, and every notification after it is ignored. Disposing the observer stops it the same way.

Implementations

impl<T: 'static> ObserverBase<T>

pub fn new(core: impl ObserverCore<T> + 'static) -> Self

An observer of the handlers of core (a subclass of ObserverBase<T> upstream).

pub fn from_fns( on_next_core: impl Fn(T) + 'static, on_error_core: impl Fn(ObservableError) + 'static, on_completed_core: impl Fn() + 'static, ) -> Self

An observer whose handlers are the three functions.

Trait Implementations

impl<T> IDisposable for ObserverBase<T>

fn dispose(&self)

Stops the observer: later notifications are ignored (Dispose).

impl<T: 'static> IObserver<T> for ObserverBase<T>

fn on_next(&self, value: T)

Hands the value to the core unless the observer is stopped (OnNext).

fn on_error(&self, error: ObservableError)

Stops the observer and hands the error to the core, the first time (OnError).

fn on_completed(&self)

Stops the observer and tells the core, the first time (OnCompleted).