Struct BoxedObserver 

pub struct BoxedObserver<'or, T, E>(/* private fields */);

Type-erased observer for multi-threaded builds to handle this problem https://stackoverflow.com/q/46620790/9315497

Implementations

impl<'or, T, E> BoxedObserver<'or, T, E>

pub fn new(observer: impl Observer<T, E> + NecessarySendSync + 'or) -> Self

Trait Implementations

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

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

Formats the value using the given formatter.

impl<T, E> Observer<T, E> for BoxedObserver<'_, 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.