Struct UnboundedReceiver

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

The receiving half of an unbounded MPSC channel

Implementations

impl<T> UnboundedReceiver<T>

pub async fn recv(&mut self) -> Option<T>

Receives a value from the channel asynchronously

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

Attempts to receive a value without blocking

pub fn id(&self) -> usize

Returns a unique identifier for this channel based on the shared pointer address

pub fn is_closed(&self) -> bool

Checks if the channel is closed and empty

pub fn is_empty(&self) -> bool

Checks if the channel is currently empty

pub fn close(&mut self)

Closes the receiving half of the channel without dropping it

pub fn sender_strong_count(&self) -> usize

Returns the number of UnboundedSender handles.

pub fn sender_weak_count(&self) -> usize

Returns the number of WeakUnboundedSender handles.

pub fn len(&self) -> usize

Returns the number of messages in the channel.

Trait Implementations

impl<T> Drop for UnboundedReceiver<T>

fn drop(&mut self)

Executes the destructor for this type.