Trait SharedEmitter 

pub trait SharedEmitter: Emitter {
    // Required method
    fn emit<O>(self, subscriber: Subscriber<O, SharedSubscription>)
       where O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static;
}

Required Methods

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

where O: Observer<Item = Self::Item, Err = Self::Err> + Send + Sync + 'static,

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 SharedEmitter for NeverEmitter

impl<Err> SharedEmitter for ThrowEmitter<Err>

impl<F, Item, Err> SharedEmitter for FnEmitter<F, Item, Err>

where F: FnOnce(Subscriber<Box<dyn Observer<Item = Item, Err = Err> + Send + Sync + 'static>, SharedSubscription>),

impl<F, Item: 'static, Emit, Err: 'static> SharedEmitter for DeferEmitter<F, Item, Err>

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

impl<Item> SharedEmitter for OfEmitter<Item>

impl<Item> SharedEmitter for OptionEmitter<Item>

impl<Item> SharedEmitter for EmptyEmitter<Item>

impl<Item, Err> SharedEmitter for ResultEmitter<Item, Err>

impl<Item, F> SharedEmitter for CallableEmitter<F>

where F: FnOnce() -> Item,

impl<Item: Send + 'static, S: SharedScheduler + 'static> SharedEmitter for TimerEmitter<Item, S>

impl<S: SharedScheduler + 'static> SharedEmitter for IntervalEmitter<S>