Trait rxrs::observable::ObserverHelper

pub trait ObserverHelper<V> {
    fn next(&self, _: V) { ... }
    fn err(&self, _: ArcErr) { ... }
    fn complete(&self) { ... }
    fn _is_closed(&self) -> bool { ... }
}

Provided Methods

fn next(&self, _: V)

fn err(&self, _: ArcErr)

fn complete(&self)

fn _is_closed(&self) -> bool

Implementations on Foreign Types

impl<V, FErr: Fn(ArcErr)> ObserverHelper<V> for ((), FErr)

fn err(&self, e: ArcErr)

fn next(&self, _: V)

fn complete(&self)

fn _is_closed(&self) -> bool

impl<V, FComp: Fn()> ObserverHelper<V> for ((), (), FComp)

fn complete(&self)

fn next(&self, _: V)

fn err(&self, _: ArcErr)

fn _is_closed(&self) -> bool

impl<V, F: Fn(V), FErr: Fn(ArcErr), FComp: Fn()> ObserverHelper<V> for (F, FErr, FComp)

fn next(&self, v: V)

fn err(&self, e: ArcErr)

fn complete(&self)

fn _is_closed(&self) -> bool

impl<V, F: Fn(V), FErr: Fn(ArcErr)> ObserverHelper<V> for (F, FErr)

fn next(&self, v: V)

fn err(&self, e: ArcErr)

fn complete(&self)

fn _is_closed(&self) -> bool

impl<V, FErr: Fn(ArcErr), FComp: Fn()> ObserverHelper<V> for ((), FErr, FComp)

fn err(&self, e: ArcErr)

fn complete(&self)

fn next(&self, _: V)

fn _is_closed(&self) -> bool

impl<V, F: Fn(V), FComp: Fn()> ObserverHelper<V> for (F, (), FComp)

fn next(&self, v: V)

fn complete(&self)

fn err(&self, _: ArcErr)

fn _is_closed(&self) -> bool

impl<V> ObserverHelper<V> for Arc<Observer<V>>

fn next(&self, v: V)

fn err(&self, e: ArcErr)

fn complete(&self)

fn _is_closed(&self) -> bool

Implementors

• impl<V, F: Fn(V)> ObserverHelper<V> for F