Struct Receiver 

pub struct Receiver<T>(/* private fields */);

Receiver for unbounded MPSC channel.

Only one receiver exists per channel.

Implementations

impl<T> Receiver<T>

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

Block until a value is received.

Errors

Returns Err(RecvError) if the channel is closed.

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

Try to receive without blocking.

Errors

Returns Err(TryRecvError::Empty) if no message is available, or Err(TryRecvError::Disconnected) if the channel is closed.

pub fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvError>

Block until a value is received or timeout expires.

Errors

Returns Err(RecvError) on timeout or if channel is closed.

pub fn iter(&self) -> impl Iterator<Item = T> + '_

Create an iterator over received values.

pub fn try_iter(&self) -> impl Iterator<Item = T> + '_

Try to receive all available values without blocking.

Trait Implementations

impl<T> Debug for Receiver<T>

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

Formats the value using the given formatter.