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.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

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

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