Trait rxrust::observable::Connect

pub trait Connect {
    type R;
    type Unsub;
    fn into_ref_count(self) -> Self::R;
    fn connect(self) -> Self::Unsub;
}

Associated Types

type R

type Unsub

Required methods

fn into_ref_count(self) -> Self::R

fn connect(self) -> Self::Unsub

Implementors

impl<'a, Src> Connect for ConnectableObservable<Src, LocalSubject<'a, Src::Item, Src::Err>> where
    Src: LocalObservable<'a>,
    Src::Item: Clone + 'a,
    Src::Err: Clone + 'a, 

type R = RefCount<MutRc<InnerRefCount<Src, LocalSubject<'a, <Src as Observable>::Item, <Src as Observable>::Err>, <Src as LocalObservable<'a>>::Unsub>>>

type Unsub = Src::Unsub

impl<Src> Connect for ConnectableObservable<Src, SharedSubject<Src::Item, Src::Err>> where
    Src: SharedObservable,
    Src::Item: Clone + Send + Sync + 'static,
    Src::Err: Clone + Send + Sync + 'static, 

type R = RefCount<MutArc<InnerRefCount<Src, SharedSubject<<Src as Observable>::Item, <Src as Observable>::Err>, <Src as SharedObservable>::Unsub>>>

type Unsub = Src::Unsub