Trait rxrust::observer::Observer

pub trait Observer {
    type Item;
    type Err;
    fn next(&mut self, value: Self::Item);
    fn error(&mut self, err: Self::Err);
    fn complete(&mut self);
}

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.

Associated Types

type Item

type Err

Required methods

fn next(&mut self, value: Self::Item)

fn error(&mut self, err: Self::Err)

fn complete(&mut self)

Implementations on Foreign Types

impl<Item, Err, T> Observer for Box<T> where
    T: Observer<Item = Item, Err = Err> + ?Sized, 

type Item = Item

type Err = Err

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

impl<'a, O> Observer for Rc<RefCell<LocalMergeAllObserver<'a, O>>> where
    O: Observer + 'a, 

type Item = LocalBoxOp<'a, O::Item, O::Err>

type Err = O::Err

fn next(&mut self, value: Self::Item)

fn error(&mut self, err: Self::Err)

fn complete(&mut self)

impl<O> Observer for Arc<Mutex<SharedMergeAllObserver<O>>> where
    O: Observer + Send + Sync + 'static, 

type Item = SharedBoxOp<O::Item, O::Err>

type Err = O::Err

fn next(&mut self, value: Self::Item)

fn error(&mut self, err: Self::Err)

fn complete(&mut self)

Implementors

impl<'a, Inner, O, Item, Err> Observer for FlattenOuterObserver<Inner, MutRc<FlattenInnerObserver<O, LocalSubscription, MutRc<FlattenState>>>, LocalSubscription, MutRc<FlattenState>> where
    O: Observer<Item = Item, Err = Err> + 'a,
    Inner: LocalObservable<'a, Item = Item, Err = Err>,
    Inner::Unsub: 'static, 

type Item = Inner

type Err = O::Err

impl<'a, Item: Clone, Err: Clone> Observer for LocalSubject<'a, Item, Err>

type Item = Item

type Err = Err

impl<'a, Obs, Source, Discr, Key, Item, Err> Observer for GroupByObserver<Obs, Source, Discr, Key, Item> where
    Obs: Observer<Item = GroupObservable<Source, Discr, Key>, Err = Err>,
    Source: Observable + Clone,
    Discr: FnMut(&Item) -> Key + Clone,
    Key: Hash + Clone + Eq, 

type Item = Item

type Err = Err

impl<Inner, O> Observer for FlattenOuterObserver<Inner, MutArc<FlattenInnerObserver<O, SharedSubscription, MutArc<FlattenState>>>, SharedSubscription, MutArc<FlattenState>> where
    O: Observer + Sync + Send + 'static,
    Inner: SharedObservable<Item = O::Item, Err = O::Err>, 

type Item = Inner

type Err = O::Err

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

type Item = InputItem

type Err = Err

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

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

type Item = Item

type Err = Err

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

type Item = Item

type Err = Err

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

type Item = Item

type Err = Err

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

type Item = Item

type Err = Err

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

type Item = Item

type Err = Err

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

type Item = Item

type Err = Err

impl<Item, Err, O, F> Observer for TapObserver<O, F, Item> where
    O: Observer<Item = Item, Err = Err>,
    F: FnMut(&Item), 

type Item = Item

type Err = Err

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

type Item = Item

type Err = Err

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

type Item = Item

type Err = Err

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

type Item = Item

type Err = Err

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

type Item = Item

type Err = ()

impl<Item: Clone, Err: Clone> Observer for SharedSubject<Item, Err>

type Item = Item

type Err = Err

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

type Item = Item

type Err = ()

impl<O, B, U, Item> Observer for BufferWithCountOrTimerObserver<O, B, U> where
    O: Observer<Item = Vec<Item>>,
    B: RcDerefMut + 'static,
    for<'r> B::Target<'r>: DerefMut<Target = O::Item>,
    U: SubscriptionLike, 

type Item = Item

type Err = O::Err

impl<O, B, U, Item, Err> Observer for BufferWithTimeObserver<O, B, U> where
    O: Observer<Item = Vec<Item>, Err = Err>,
    B: RcDerefMut + 'static,
    U: SubscriptionLike,
    for<'r> B::Target<'r>: DerefMut<Target = O::Item>, 

type Item = Item

type Err = Err

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

type Item = Item

type Err = Err

impl<O, Item, Err> Observer for BufferWithCountObserver<O, Item> where
    O: Observer<Item = Vec<Item>, Err = Err>, 

type Item = Item

type Err = Err

impl<O, Item, Err> Observer for ContainsObserver<O, Item> where
    O: Observer<Item = bool, Err = Err>,
    Item: Clone + Eq, 

type Item = Item

type Err = Err

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

type Item = Item

type Err = Err

impl<O, Item, Err> Observer for PairwiseObserver<O, Item> where
    O: Observer<Item = (Item, Item), Err = Err>,
    Item: Clone, 

type Item = Item

type Err = Err

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

type Item = Item

type Err = Err

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

type Item = Item

type Err = Err

impl<O, S> Observer for MutArc<DebounceObserver<O, S, O::Item>> where
    O: Observer + Send + 'static,
    O::Item: Clone + Send,
    S: SharedScheduler + Send + 'static, 

type Item = O::Item

type Err = O::Err

impl<O, S> Observer for MutRc<DebounceObserver<O, S, O::Item>> where
    O: Observer + 'static,
    O::Item: Clone,
    S: LocalScheduler + 'static, 

type Item = O::Item

type Err = O::Err

impl<O, SD> Observer for MutArc<ThrottleObserver<O, SD>> where
    O: Observer + Send + 'static,
    SD: SharedScheduler + Send + 'static,
    O::Item: Clone + Send + 'static, 

type Item = O::Item

type Err = O::Err

impl<O, SD> Observer for MutRc<ThrottleObserver<O, SD>> where
    O: Observer + 'static,
    SD: LocalScheduler + 'static,
    O::Item: Clone + 'static, 

type Item = O::Item

type Err = O::Err

impl<O, U> Observer for InnerSubject<O, U> where
    O: Observer + ?Sized,
    U: SubscriptionLike,
    O::Item: Clone,
    O::Err: Clone, 

type Item = O::Item

type Err = O::Err

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

type Item = Item

type Err = Err

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

type Item = Item

type Err = Err

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

type Item = NotifierItem

type Err = Err

impl<O, U, S> Observer for FlattenInnerObserver<O, U, S> where
    O: Observer,
    U: SubscriptionLike,
    S: RcDerefMut,
    for<'r> S::Target<'r>: DerefMut<Target = FlattenState>, 

type Item = O::Item

type Err = O::Err

impl<S, Item> Observer for BehaviorSubject<S, Item> where
    S: Observer,
    S::Item: Clone,
    Item: RcDerefMut,
    for<'r> Item::Target<'r>: DerefMut<Target = S::Item>, 

type Item = S::Item

type Err = S::Err

impl<T> Observer for MutArc<T> where
    T: Observer, 

type Item = T::Item

type Err = T::Err

impl<T> Observer for MutRc<T> where
    T: Observer, 

type Item = T::Item

type Err = T::Err

impl<T, Item, Err> Observer for BufferedMutArc<T, Item, Err> where
    T: Observer<Item = Item, Err = Err>, 

type Item = Item

type Err = Err

impl<T, Item, Err> Observer for BufferedMutRc<T, Item, Err> where
    T: Observer<Item = Item, Err = Err>, 

type Item = Item

type Err = Err