Struct mpmc_async::Receiver

pub struct Receiver<T>
where
    T: Send + Sync + 'static,
{ /* private fields */ }

Receives messages sent by Sender.

Implementations

impl<T> Receiver<T>

where T: Send + Sync + 'static,

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

Waits until there’s a message to be read and returns. Returns an error when there are no more messages in the queue and all Senders have been dropped.

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

Checks if there’s a message to be read and returns immediately. Returns an error when the channel is disconnected or empty.

Trait Implementations

impl<T> Clone for Receiver<T>

where T: Send + Sync + 'static,

Cloning creates new a instance with the shared state and increases the internal reference counter. It is guaranteed that a single message will be distributed to exacly one receiver future awaited after calling recv().

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Drop for Receiver<T>

where T: Send + Sync + 'static,

The last reciever that’s dropped will mark the channel as disconnected.

fn drop(&mut self)

Executes the destructor for this type.