Struct Observer 

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

An Observer watching for a single message T.

This is similar to the ‘receiver’ end of a channel of length 1, but instead of blocking, the ‘sender’ always overwrites any element in the channel. In particular, any message obtained by recv or try_recv is guaranteed to be the most up-to-date at the moment when the message is received.

The channel may be updated when not observed. Receiving a message moves it out of the observer. An observer can be cheaply cloned (a single Arc::clone) in order to watch for the message simultaneously from different threads.

Implementations

impl<T> Observer<T>

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

Receive a message, blocking until a message is available or the channel disconnects.

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

Optimistically receive a message if one is available without blocking the current thread.

This operation will fail if there is no message or if there are are no remaining senders.

Trait Implementations

impl<T> Clone for Observer<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.