Trait rxrust::observable::SubscribeNext

pub trait SubscribeNext<'a, N> {
    type Unsub: SubscriptionLike;
    fn subscribe(self, next: N) -> SubscriptionWrapper<Self::Unsub>;
}

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::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::Unsub