Type Definition rxrust::subject::LocalSubject

type LocalSubject<'a, Item, Err> = Subject<LocalObserver<Box<dyn Publisher<Item, Err> + 'a>>, 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<Arc<Mutex<Vec<Box<dyn Publisher<Item, Err> + Send + Sync>>>>, SharedSubscription>

fn to_shared(self) -> Self::Shared

impl<'a, Item, Err, O, U> RawSubscribable<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