Trait LocalEmitter 

pub trait LocalEmitter<'a>: Emitter {
    // Required method
    fn emit<O>(self, subscriber: Subscriber<O, LocalSubscription>)
       where O: Observer<Item = Self::Item, Err = Self::Err> + 'a;
}

Required Methods

fn emit<O>(self, subscriber: Subscriber<O, LocalSubscription>)

where O: Observer<Item = Self::Item, Err = Self::Err> + 'a,

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<'a> LocalEmitter<'a> for NeverEmitter

impl<'a, Err> LocalEmitter<'a> for ThrowEmitter<Err>

impl<'a, F, Emit, Item, Err> LocalEmitter<'a> for DeferEmitter<F, Item, Err>

where F: FnOnce() -> Emit, Emit: LocalObservable<'a> + Observable<Item = Item, Err = Err>,

impl<'a, F, Item, Err> LocalEmitter<'a> for FnEmitter<F, Item, Err>

where F: FnOnce(Subscriber<Box<dyn Observer<Item = Item, Err = Err> + 'a>, Box<dyn SubscriptionLike + 'a>>),

impl<'a, Item> LocalEmitter<'a> for OfEmitter<Item>

impl<'a, Item> LocalEmitter<'a> for OptionEmitter<Item>

impl<'a, Item> LocalEmitter<'a> for EmptyEmitter<Item>

impl<'a, Item, Err> LocalEmitter<'a> for ResultEmitter<Item, Err>

impl<'a, Item, F> LocalEmitter<'a> for CallableEmitter<F>

where F: FnOnce() -> Item,

impl<Item: 'static, S: LocalScheduler + 'static> LocalEmitter<'static> for TimerEmitter<Item, S>

impl<S: LocalScheduler + 'static> LocalEmitter<'static> for IntervalEmitter<S>