Struct batch_channel::BatchSender

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

Automatically sends values on the channel in batches.

Any unsent values are sent upon drop.

Implementations

impl<T> BatchSender<T>

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

Buffers a single value to be sent on the channel.

Sends the batch if the buffer is full.

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

Buffers multiple values, sending batches as the internal buffer reaches capacity.

pub fn drain(&mut self) -> Result<(), SendError<()>>

Sends any buffered values, clearing the current batch.

Trait Implementations

impl<T: Debug> Debug for BatchSender<T>

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

Formats the value using the given formatter.

impl<T> Drop for BatchSender<T>

Sends remaining values.

fn drop(&mut self)

Executes the destructor for this type.