Struct mpmc_async::Sender

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

Producers messages to be read by Receivers.

Implementations

impl<T> Sender<T>

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.

pub async fn reserve_many( &self, count: usize ) -> Result<PermitIterator<'_, T>, ReserveError>

Waits until multiple Permits in the queue are reserved.

pub fn try_reserve_many( &self, count: usize ) -> Result<PermitIterator<'_, T>, TryReserveError>

Reserves multiple Permits in the queue, or errors out when there’s no room.

pub async fn reserve_owned(self) -> Result<OwnedPermit<T>, ReserveError>

Like Sender::reserve, but takes ownership of Sender until sending is done.

pub fn try_reserve_owned(self) -> Result<OwnedPermit<T>, TrySendError<Self>>

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

Trait Implementations

impl<T> Clone for Sender<T>

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> Debug for Sender<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Drop for Sender<T>

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

fn drop(&mut self)

Executes the destructor for this type.