[−][src]Trait rxrust::observable::SubscribeErr
Associated Types
type Unsub: SubscriptionLike[src]
A type implementing SubscriptionLike
Required methods
pub fn subscribe_err(
self,
next: N,
error: E
) -> SubscriptionWrapper<Self::Unsub>[src]
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, [src]
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
pub fn subscribe_err(
self,
next: N,
error: E
) -> SubscriptionWrapper<Self::Unsub> where
Self: Sized, [src]
self,
next: N,
error: E
) -> SubscriptionWrapper<Self::Unsub> where
Self: Sized,
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, [src]
S: LocalObservable<'a>,
N: FnMut(S::Item) + 'a,
E: FnMut(S::Err) + 'a,
S::Err: 'a,
S::Item: 'a,
type Unsub = S::Unsub
pub fn subscribe_err(
self,
next: N,
error: E
) -> SubscriptionWrapper<Self::Unsub>[src]
self,
next: N,
error: E
) -> SubscriptionWrapper<Self::Unsub>