Struct Receiver 

pub(crate) struct Receiver<T>(Arc<Channel<T>>);

The receiving half of a channel, whose clones share the messages.

Tuple Fields

0: Arc<Channel<T>>

Implementations

impl<T> Receiver<T>

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

Receive the oldest message, waiting while the channel is empty. Fails once the channel is empty and got closed or all senders are gone.

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

Receive the oldest message without waiting.

pub(crate) fn close(&self)

Close the channel for all senders and receivers. Sending fails from now on, waiting senders give up, the queued messages can still be received.

Trait Implementations

impl<T> Clone for Receiver<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for Receiver<T>

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

Formats the value using the given formatter.

impl<T> Drop for Receiver<T>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.