Trait pharos::UnboundedObservable

pub trait UnboundedObservable<Event> where
    Event: Clone + 'static + Send, {
    fn observe_unbounded(&mut self) -> UnboundedReceiver<Event>;
}

Indicate that a type is observable through an unbounded stream. You can call observe_unbounded to get a stream of events.

Required methods

fn observe_unbounded(&mut self) -> UnboundedReceiver<Event>

Add an observer to the observable. This will use an unbounded channel. Beware that if the observable outpaces the observer, this will lead to growing memory consumption over time.

Loading content...

Implementors

Loading content...