Struct CallbackObserver 

pub struct CallbackObserver<FN, FT> { /* private fields */ }

Implementations

impl<FN, FT> CallbackObserver<FN, FT>

pub fn new<T, E, R>(on_next: FN, on_termination: FT) -> Self

where FN: FnMut(T) -> R, R: IntoFlow, FT: FnOnce(Termination<E>),

Trait Implementations

impl<FN, FT> Clone for CallbackObserver<FN, FT>

where FN: Clone, FT: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<FN, FT> Debug for CallbackObserver<FN, FT>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T, E, R, FN, FT> Observer<T, E> for CallbackObserver<FN, FT>

where FN: FnMut(T) -> R, R: IntoFlow, FT: FnOnce(Termination<E>),

fn on_next(&mut self, value: T) -> Flow

Called when the next value in the operation is available.

fn on_termination(self, termination: Termination<E>)

Called when the operation has reached its termination state.