Struct Subject 

pub struct Subject<T> { /* private fields */ }

Stores the observers for a particular event

Implementations

impl<T> Subject<T>

pub fn new() -> Subject<T>

Creates a new empty set of observers

Trait Implementations

impl<T: Send + Sync + Clone + 'static> Observable<T> for Subject<T>

fn subscribe<S: Observer<T> + 'static>(&self, observer: &Arc<S>)

Adds a weakly held observer

fn poll(&self) -> T

Waits indefinitely for an event to be emitted

fn poll_timeout(&self, duration: Duration) -> Result<T>

Waits for an event to be emitted with a timeout

impl<T> Observer<T> for Subject<T>

fn next(&self, event: &T)

Called when the event occurs