Struct GenericBufferedSender 

pub struct GenericBufferedSender<T, U>
where
    T: Serialize,
{
    sender: GenericSender<T>,
    buffer: RefCell<Vec<U>>,
    buffering: Box<dyn Fn(Vec<U>) -> T>,
    max_buffer: usize,
}

A buffered sender that collects individual messages (U) and sends them as a single batched message (T) via a user-provided packing closure.

The buffer is flushed automatically when it reaches max_buffer items, or explicitly via flush. send_immediate combines the current buffer contents with the new message into a single packed message, ensuring ordering without an extra flush step.

Fields

sender: GenericSender<T>

buffer: RefCell<Vec<U>>

buffering: Box<dyn Fn(Vec<U>) -> T>

max_buffer: usize

Implementations

impl<T: Serialize, U> GenericBufferedSender<T, U>

pub fn new( sender: GenericSender<T>, buffering: Box<dyn Fn(Vec<U>) -> T>, max_buffer: usize, ) -> Self

Create a new buffered sender.

• sender — the underlying GenericSender<T> that delivers packed messages.
• buffering — closure that packs a Vec<U> into a single T.
• max_buffer — automatic flush is triggered when the buffer reaches this size.

pub fn is_empty(&self) -> bool

Returns true if the buffer contains no pending messages.

pub fn len(&self) -> usize

Returns the number of pending messages in the buffer.

pub fn set_max_buffer(&mut self, max: usize)

Change the auto-flush threshold.

pub fn send(&self, msg: U) -> SendResult

Buffer a message for later batched delivery.

If the buffer reaches max_buffer items an automatic flush is triggered.

pub fn send_immediate(&self, msg: U) -> SendResult

Deliver a message immediately, combining it with any buffered messages into a single packed T.

pub fn flush(&self) -> SendResult

Flush all buffered messages by packing them into a single T and sending it.

Trait Implementations

impl<T: Serialize, U> Drop for GenericBufferedSender<T, U>

fn drop(&mut self)

Executes the destructor for this type.