Trait rxrust::observer::Observer

pub trait Observer<Item, Err> {
    fn next(&mut self, value: Item);
    fn error(&mut self, err: Err);
    fn complete(&mut self);
    fn is_stopped(&self) -> bool;
}

An Observer is a consumer of values delivered by an Observable. One for each type of notification delivered by the Observable: next, error, and complete.

Item the type of the elements being emitted. Errthe type of the error may propagating.

Required methods

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

Loading content...

Implementors

impl<InputItem, Err, Source, BinaryOp, OutputItem> Observer<InputItem, Err> for ScanObserver<Source, BinaryOp, OutputItem> where
    Source: Observer<OutputItem, Err>,
    BinaryOp: FnMut(OutputItem, InputItem) -> OutputItem,
    OutputItem: Clone, 

fn next(&mut self, value: InputItem)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

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

fn next(&mut self, err: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

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

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<Item, Err, O> Observer<Item, Err> for DefaultIfEmptyObserver<O, Item> where
    O: Observer<Item, Err>,
    Item: Clone, 

fn next(&mut self, value: Item)

fn complete(&mut self)

fn error(&mut self, err: Err)

fn is_stopped(&self) -> bool

impl<Item, Err, O> Observer<Item, Err> for SkipLastObserver<O, Item> where
    O: Observer<Item, Err>, 

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<Item, Err, O> Observer<Item, Err> for TakeLastObserver<O, Item> where
    O: Observer<Item, Err>, 

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<Item, Err, O, B> Observer<Item, Err> for MapToObserver<O, B> where
    O: Observer<B, Err>,
    B: Clone, 

fn next(&mut self, _: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<Item, Err, O, F> Observer<Item, Err> for FilterObserver<O, F> where
    O: Observer<Item, Err>,
    F: FnMut(&Item) -> bool, 

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<Item, Err, O, M, B> Observer<Item, Err> for MapObserver<O, M> where
    O: Observer<B, Err>,
    M: FnMut(Item) -> B, 

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<Item, Err, O, U> Observer<Item, Err> for SkipObserver<O, U> where
    O: Observer<Item, Err>,
    U: SubscriptionLike, 

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<Item, Err, O, U> Observer<Item, Err> for Subscriber<O, U> where
    O: Observer<Item, Err>,
    U: SubscriptionLike, 

fn next(&mut self, v: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<Item, Err, O, Unsub> Observer<Item, Err> for MergeObserver<O, Unsub> where
    O: Observer<Item, Err>,
    Unsub: SubscriptionLike, 

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<Item, Err, T> Observer<Item, Err> for T where
    T: InnerDerefMut,
    T::Target: Observer<Item, Err>, 

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<Item, Err, U, O, V> Observer<Item, Err> for Subject<V, U> where
    V: InnerDerefMut<Target = Vec<O>>,
    O: Observer<Item, Err> + SubscriptionLike,
    Item: Clone,
    Err: Clone, 

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<Item, N> Observer<Item, ()> for ObserverN<N> where
    N: FnMut(Item), 

fn next(&mut self, value: Item)

fn error(&mut self, _err: ())

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<N, C, Item> Observer<Item, ()> for ObserverComp<N, C> where
    C: FnMut(),
    N: FnMut(Item), 

fn next(&mut self, value: Item)

fn error(&mut self, _err: ())

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<O, F, Item, Err, OutputItem> Observer<Item, Err> for FilterMapObserver<O, F> where
    O: Observer<OutputItem, Err>,
    F: FnMut(Item) -> Option<OutputItem>, 

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<O, Item, Err> Observer<Item, Err> for FirstOrObserver<O, Item> where
    O: Observer<Item, Err>, 

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<O, Item, Err> Observer<Item, Err> for LastOrObserver<O, Item> where
    O: Observer<Item, Err>, 

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<O, U, Item, Err> Observer<Item, Err> for TakeObserver<O, U> where
    O: Observer<Item, Err>,
    U: SubscriptionLike, 

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<O, U, Item, Err, F> Observer<Item, Err> for TakeWhileObserver<O, U, F> where
    O: Observer<Item, Err>,
    U: SubscriptionLike,
    F: FnMut(&Item) -> bool, 

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<O, U, NotifierItem, Item, Err> Observer<NotifierItem, Err> for TakeUntilNotifierObserver<O, U, Item> where
    O: Observer<Item, Err>,
    U: SubscriptionLike, 

fn next(&mut self, _: NotifierItem)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

Loading content...