Trait rxrust::observable::SubscribeComplete

pub trait SubscribeComplete<'a, N, C> {
    type Unsub: SubscriptionLike;
    fn subscribe_complete(
        self, 
        next: N, 
        complete: C
    ) -> SubscriptionWrapper<Self::Unsub>;
}

Associated Types

type Unsub: SubscriptionLike

A type implementing SubscriptionLike

Required methods

fn subscribe_complete(
    self,
    next: N,
    complete: C
) -> SubscriptionWrapper<Self::Unsub>

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

Implementors

impl<'a, S, N, C> SubscribeComplete<'a, N, C> for Shared<S> where
    S: SharedObservable<Err = ()>,
    C: FnMut() + Send + Sync + 'static,
    N: FnMut(S::Item) + Send + Sync + 'static,
    S::Item: 'static, 

type Unsub = S::Unsub

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

type Unsub = S::Unsub