Struct Receiver 

pub struct Receiver<T: Copy + 'static, const N: usize> { /* private fields */ }

Multi-consumer half of an ove::channel.

Implementations

impl<T: Copy + 'static, const N: usize> Receiver<T, N>

pub const unsafe fn from_static( queue: &'static Queue<T, N>, tx_count: &'static AtomicUsize, rx_count: &'static AtomicUsize, ) -> Self

Construct a receiver from caller-owned static state. See Sender::from_static for the safety + count-initialisation contract.

Safety

Same as Sender::from_static.

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

Receive an item. Blocks until a sender posts, or returns Error::NetClosed when every Sender has been dropped and the queue is empty.

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

Non-blocking receive. Returns Error::Timeout when empty and senders are still alive; Error::NetClosed when empty and all senders are gone.

pub fn sender_count(&self) -> usize

Number of currently-live Sender handles.

pub fn receiver_count(&self) -> usize

Number of currently-live Receiver handles.

Trait Implementations

impl<T: Copy + 'static, const N: usize> Clone for Receiver<T, N>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Copy + 'static, const N: usize> Drop for Receiver<T, N>

fn drop(&mut self)

Executes the destructor for this type.