Trait rxrust::observable::SubscribeErr

pub trait SubscribeErr<'a, N, E> {
    type Unsub: SubscriptionLike;
    fn subscribe_err(
        self, 
        next: N, 
        error: E
    ) -> SubscriptionWrapper<Self::Unsub>;
}

Associated Types

type Unsub: SubscriptionLike

A type implementing SubscriptionLike

Required methods

fn subscribe_err(self, next: N, error: E) -> SubscriptionWrapper<Self::Unsub>

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

• error: A handler for a terminal event resulting from an error. completion.

Implementors

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

type Unsub = S::Unsub

impl<'a, S, N, E> SubscribeErr<'a, N, E> for S where
    S: LocalObservable<'a>,
    N: FnMut(S::Item) + 'a,
    E: FnMut(S::Err) + 'a,
    S::Err: 'a,
    S::Item: 'a, 

type Unsub = S::Unsub