Type Definition rxrust::subject::LocalSubject

type LocalSubject<'a, Item, Err> = Subject<LocalPublishers<'a, Item, Err>, LocalSubscription>;

Methods

impl<'a, Item, Err> LocalSubject<'a, Item, Err>

pub fn local() -> Self

Trait Implementations

impl<'a, Item, Err> IntoShared for LocalSubject<'a, Item, Err> where
    Item: 'static,
    Err: 'static, 

type Shared = Subject<SharedPublishers<Item, Err>, SharedSubscription>

fn to_shared(self) -> Self::Shared

impl<'a, Item, Err, O, U> RawSubscribable<Item, Err, Subscriber<O, U>> for LocalSubject<'a, Item, Err> where
    O: Observer<Item, Err> + 'a,
    U: SubscriptionLike + Clone + 'static, 

type Unsub = U

A type implementing SubscriptionLike

fn raw_subscribe(self, subscriber: Subscriber<O, U>) -> Self::Unsub