Struct rxrust::observable::ObserverErr

pub struct ObserverErr<N, E, Item, Err> { /* fields omitted */ }

Implementations

impl<N, E, Item, Err> ObserverErr<N, E, Item, Err>

pub fn new(next: N, error: E) -> Self

Trait Implementations

impl<N: Clone, E: Clone, Item: Clone, Err: Clone> Clone for ObserverErr<N, E, Item, Err>

fn clone(&self) -> ObserverErr<N, E, Item, Err>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Item, Err, N, E> Observer for ObserverErr<N, E, Item, Err> where
    N: FnMut(Item),
    E: FnMut(Err), 

type Item = Item

type Err = Err

fn next(&mut self, err: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool