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".

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, 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<Item> SharedEmitter for EmptyEmitter<Item>

impl<Item> SharedEmitter for OfEmitter<Item>

impl<Item> SharedEmitter for OptionEmitter<Item>

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