Struct batch_channel::BoundedBatchSender

pub struct BoundedBatchSender<T: 'static> { /* private fields */ }

The internal send handle used by BoundedSender::autobatch. Builds a buffer of size capacity and flushes when it’s full.

Implementations

impl<T> BoundedBatchSender<T>

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

Adds a value to the internal buffer and flushes it into the queue when the buffer fills.