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) -> Option<T>

Retrieve the next available element from the queue. Returns None if the queue is empty.

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>