Struct CallbackObserver 

pub struct CallbackObserver<'cb, T, E> { /* private fields */ }

Observer implementation backed by user-provided callbacks.

Implementations

impl<'cb, T, E> CallbackObserver<'cb, T, E>

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

where FN: FnMut(T) + NecessarySendSync + 'cb, FT: FnOnce(Termination<E>) + NecessarySendSync + 'cb,

Trait Implementations

impl<T, E> Debug for CallbackObserver<'_, T, E>

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

Formats the value using the given formatter.

impl<T, E> Observer<T, E> for CallbackObserver<'_, T, E>

fn on_next(&mut self, value: T)

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.