Trait sv::util::rx::Observable

pub trait Observable<T: Send + Sync + Clone + 'static> {
    fn subscribe<S: Observer<T> + 'static>(&self, observer: &Arc<S>);

    fn poll(&self) -> T { ... }
    fn poll_timeout(&self, duration: Duration) -> Result<T> { ... }
}

Event publisher that may be subscribed to

Required Methods

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

Adds a weakly held observer

Provided Methods

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

Implementors

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

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

fn poll(&self) -> T

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

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

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

fn poll(&self) -> T

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