Struct BufferedSender 

pub struct BufferedSender<'a, T: Send> { /* private fields */ }

A BufferedChannel sender that buffers messages locally, flushing it when the sender is dropped or BufferedChannel::chunk_size is reached.

Implementations

impl<'a, T: Send> BufferedSender<'a, T>

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

Send a message asynchronously.

This is buffered and will not be sent into the channel until BufferedChannel::chunk_size messages are accumulated or the sender is dropped.

pub fn send_blocking(&mut self, msg: T) -> Result<(), SendError<Vec<T>>>

Send an item blocking.

This is buffered and will not be sent into the channel until BufferedChannel::chunk_size messages are accumulated or the sender is dropped.

pub fn flush(&mut self)

Flush any remaining messages in the local buffer, sending them into the channel.

Trait Implementations

impl<'a, T: Send> Clone for BufferedSender<'a, T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a, T: Send> Drop for BufferedSender<'a, T>

Automatically flush the buffer when a sender is dropped.

fn drop(&mut self)

Executes the destructor for this type.