Struct AnonymousObserver 

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

An observer built from closures.

An observer without a closure for errors rethrows an error it is given (it panics with the message of the error); one without a closure for completion ignores it.

Implementations

impl<T> AnonymousObserver<T>

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

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

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

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

pub fn with_error(self, on_error: impl Fn(ObservableError) + 'static) -> Self

pub fn with_completed(self, on_completed: impl Fn() + 'static) -> Self

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)