Struct BoundedReceiver 

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

Receiver for bounded MPSC channel (same as unbounded).

Implementations

impl<T> BoundedReceiver<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 the 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 BoundedReceiver<T>

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

Formats the value using the given formatter.