Struct DistributionSender 

pub struct DistributionSender<T> {
    channel: Arc<Channel<T>>,
    gate: Arc<Gate>,
}

Sender side of distribution channels.

This handle can be cloned. All clones will write into the same channel. Dropping the last sender will close the channel. In this case, the receiver will still be able to poll the remaining data, but will receive None afterwards.

Fields

channel: Arc<Channel<T>>

To prevent lock inversion / deadlock, channel lock is always acquired prior to gate lock

gate: Arc<Gate>

Implementations

impl<T> DistributionSender<T>

pub fn send(&self, element: T) -> SendFuture<'_, T>

Send data.

This fails if the receiver is gone.

Trait Implementations

impl<T> Clone for DistributionSender<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: Debug> Debug for DistributionSender<T>

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

Formats the value using the given formatter.

impl<T> Drop for DistributionSender<T>

fn drop(&mut self)

Executes the destructor for this type.