Struct AsyncUnboundedMpscSender 

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

Async unbounded MPSC sender

Implementations

impl<T> AsyncUnboundedMpscSender<T>

pub fn try_send(&mut self, value: T) -> Result<(), PushError<T>>

Try to send without blocking

pub async fn send(&mut self, value: T) -> Result<(), PushError<T>>

Send a value asynchronously

pub fn close(&mut self) -> bool

pub fn create_blocking_sender(&self) -> BlockingUnboundedMpscSender<T>

Create a blocking sender that shares the same queue

Trait Implementations

impl<T> Clone for AsyncUnboundedMpscSender<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Drop for AsyncUnboundedMpscSender<T>

fn drop(&mut self)

Executes the destructor for this type.