Struct Sender 

pub struct Sender<T>(/* private fields */);

Implementations

impl<T> Sender<T>

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

Send a value. Returns Err(SendError(val)) if the buffer is full.

This is entirely lock-free for the enqueue step. The wakeup of a waiting receiver acquires the waiters mutex briefly.

Trait Implementations

impl<T> Clone for Sender<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 Sender<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T: Send + 'static> SelectableSender for Sender<T>

fn is_ready(&self) -> bool

Ready when the buffer is not full OR all receivers are gone (disconnect).

type Input = T

The value type this sender accepts.

fn register_select(&self, case_id: usize, selected: Arc<AtomicUsize>)

Register a send-side waiter for the select park phase.

fn abort_select(&self, selected: &Arc<AtomicUsize>)

Remove the previously registered waiter (losing arm cleanup).

fn complete_send(&self, value: T) -> Result<(), SendError<T>>

Execute the send after winning the selection. Returns Err(SendError(val)) if all receivers have been dropped.