Struct Receiver 

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

The receiving side of the spsc queue.

Implementations

impl<T> Receiver<T>

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

Retrieve the next available element from the queue without blocking.

Returns TryRecvError::Empty if the queue is currently empty, or TryRecvError::Disconnected if the Sender has been dropped and no further items can arrive.

pub fn peek(&self) -> Option<&T>

Peeks the next element in the queue without removing it.

pub fn capacity(&self) -> usize

Returns the total number of items that the queue can hold at most.

pub fn len(&self) -> usize

Returns the number of items in the queue.

WARNING

This length is only a best-effort estimate. It is computed from relaxed atomic and is NOT a linearizable value. It may be temporarily incorrect (including over/under-counting) due to reordering and visibility delays across threads.

pub fn is_empty(&self) -> bool

Returns true if the queue is empty.

WARNING

This length is only a best-effort estimate. It is computed from relaxed atomic and is NOT a linearizable value. It may be temporarily incorrect (including over/under-counting) due to reordering and visibility delays across threads.

Trait Implementations

impl<T: Debug> Debug for Receiver<T>

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

Formats the value using the given formatter.

impl<T: Send> Send for Receiver<T>

impl<T: Send> Sync for Receiver<T>