Trait SubscribeNext

pub trait SubscribeNext<'a, N> {
    type Unsub: SubscriptionLike;

    // Required method
    fn subscribe(self, next: N) -> SubscriptionWrapper<Self::Unsub>;
}

Required Associated Types

type Unsub: SubscriptionLike

A type implementing SubscriptionLike

Required Methods

fn subscribe(self, next: N) -> SubscriptionWrapper<Self::Unsub>

Invokes an execution of an Observable and registers Observer handlers for notifications it will emit.

Implementors

impl<'a, S, N> SubscribeNext<'a, N> for Shared<S>

where S: SharedObservable<Err = ()>, N: FnMut(S::Item) + Send + Sync + 'static, S::Item: 'static,

type Unsub = <S as SharedObservable>::Unsub

impl<'a, S, N> SubscribeNext<'a, N> for S

where S: LocalObservable<'a, Err = ()>, N: FnMut(S::Item) + 'a, S::Item: 'a,

type Unsub = <S as LocalObservable<'a>>::Unsub