Struct UnifiedReceiver 

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

Receiver half of a unified channel

Implementations

impl<T> UnifiedReceiver<T>

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

Receive a message (non-blocking; returns Err(Empty) when none is available).

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

Try to receive without blocking.

Identical to Self::recv — this channel has no blocking receive path. Retained for consumers written against the try_recv name.

pub fn recv_batch(&self, max_count: usize) -> Vec<T>

Receive batch of messages

pub fn is_closed(&self) -> bool

Check if channel is closed

pub fn stats(&self) -> ChannelStatistics

Get channel statistics

Trait Implementations

impl<T> Clone for UnifiedReceiver<T>

fn clone(&self) -> UnifiedReceiver<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Send for UnifiedReceiver<T>

where T: Send,

impl<T> Sync for UnifiedReceiver<T>

where T: Send,