Struct batch_channel::Sender

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

The sending half of an unbounded channel.

Implementations

impl<T> Sender<T>

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

Send a single value.

Returns SendError if all receivers are dropped.

pub fn send_iter<I>(&self, values: I) -> Result<(), SendError<I>>where I: IntoIterator<Item = T>,

Send multiple values.

If all receivers are dropped, the values are returned in SendError untouched. Either the entire batch is sent or none of it is sent.

pub fn send_vec(&self, values: Vec<T>) -> Result<Vec<T>, SendError<Vec<T>>>

Drain a Vec into the channel without deallocating it.

This is a convenience method for allocation-free batched sends. The values vector is drained, and then returned with the same capacity it had.

pub fn batch(self, capacity: usize) -> BatchSender<T>

Converts this Sender into a BatchSender with the specified capacity.

BatchSender manages a single allocation containing capacity elements and automatically sends batches as it fills.

Trait Implementations

impl<T> Clone for Sender<T>

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

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

Formats the value using the given formatter.

impl<T> Drop for Sender<T>

fn drop(&mut self)

Executes the destructor for this type.