Struct AnonymousObserver 

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

An observer made of functions (AnonymousObserver<T>). It ignores everything after a terminal notification. Without a function for errors, an error panics, as upstream rethrows it.

Implementations

impl<T> AnonymousObserver<T>

pub fn new( on_next: impl Fn(T) + 'static, on_error: impl Fn(ObservableError) + 'static, on_completed: impl Fn() + 'static, ) -> Self

An observer of the three functions.

Trait Implementations

impl<T> IObserver<T> for AnonymousObserver<T>

fn on_next(&self, value: T)

fn on_error(&self, error: ObservableError)

fn on_completed(&self)