Struct SyncBatchSender 

pub struct SyncBatchSender<'a, T> { /* private fields */ }

Automatically batches up values and sends them when a batch is full.

Implementations

impl<T> SyncBatchSender<'_, 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<'a, T: Debug> Debug for SyncBatchSender<'a, T>

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

Formats the value using the given formatter.