Struct suzy::watch::WatchedReceiver

pub struct WatchedReceiver<T> { /* fields omitted */ }

The receiver half of a watched channel.

The methods exposed on this type corospond to the non-blocking methods on the std channel Receiver, but they also bind watch closures, so that when new data is sent those closures will be re-run.

Implementations

impl<T> WatchedReceiver<T>

pub fn recv(&self) -> Result<T, TryRecvError>

Attempts to return a pending value on this receiver.

This corosponds to the try_recv method on the std Receiver, but additionally binds enclosing watch closures, so that they will be re-run when new data might be available.

pub fn iter(&self) -> TryIter<'_, T>

Returns an iterator that will attempt to yield all pending values.

This corosponds to the try_iter method on the std Receiver, but additionally binds enclosing watch closures, so that they will be re-run when new data might be available.

Trait Implementations

impl<T> Debug for WatchedReceiver<T> where
    T: Debug, 

pub fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.