Struct Receiver 

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

Implementations

impl<T> Receiver<T>

pub fn new(chan: Arc<ConcurrentQueue<T>>) -> Self

pub fn chan(&self) -> Arc<ConcurrentQueue<T>>

Get a clone of the underlying channel Arc

pub fn capacity(&self) -> Option<usize>

pub fn len(&self) -> usize

pub fn is_closed(&self) -> bool

pub fn close(&self) -> bool

pub fn is_full(&self) -> bool

pub fn is_empty(&self) -> bool

pub fn try_iter(&self) -> TryIter<'_, T>

pub fn into_recv_iter_timeout(&self, duration: Duration) -> RecvIterator<T>

pub fn into_recv_iter(&self) -> RecvIterator<T>

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

pub fn recv_timeout(&self, dur: Duration) -> Result<T, ReceiverError>

recv_timeout attempts to read value from the channel within the specified duration. It internally uses std::thread::park_timeout to block the current thread for a given duration until a value is received or the timeout is reached.

Trait Implementations

impl<T> Clone for Receiver<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.