Struct mpmc_async::Sender

pub struct Sender<T>
where
    T: Send + Sync + 'static,
{ /* private fields */ }

Producers messages to be read by Receivers.

Implementations

impl<T> Sender<T>

where T: Send + Sync + 'static,

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

Waits until the value is sent or returns an when all receivers have been dropped.

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

Sends without blocking or returns an when all receivers have been dropped.

pub async fn reserve(&self) -> Result<Permit<T>, ReserveError>

Waits until a permit is reserved or returns an when all receivers have been dropped.

pub fn try_reserve(&self) -> Result<Permit<T>, TryReserveError>

Reserves a permit or returns an when all receivers have been dropped.

Trait Implementations

impl<T> Clone for Sender<T>

where T: Send + Sync + 'static,

Cloning creates new a instance with the shared state and increases the internal reference counter.

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Drop for Sender<T>

where T: Send + Sync + 'static,

The last sender that’s dropped will mark the channel as disconnected.

fn drop(&mut self)

Executes the destructor for this type.