Trait rxrust::observable::Connect

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

Associated Types

type Unsub

Loading content...

Required methods

fn connect(self) -> Self::Unsub

Loading content...

Implementors

impl<'a, O, Item, Err> Connect for LocalConnectableObservable<'a, O, Item, Err> where
    O: RawSubscribable<Item, Err, Subscriber<LocalSubject<'a, Item, Err>, LocalSubscription>>, 

type Unsub = O::Unsub

fn connect(self) -> Self::Unsub

impl<O, Item, Err> Connect for SharedConnectableObservable<O, Item, Err> where
    O: RawSubscribable<Item, Err, Subscriber<SharedSubject<Item, Err>, SharedSubscription>>, 

type Unsub = O::Unsub

fn connect(self) -> Self::Unsub

Loading content...