Struct EventBatcher 

pub struct EventBatcher { /* private fields */ }

Batching utility for accumulating events before processing.

Implementations

impl EventBatcher

pub fn new(batch_size: usize, timeout: Duration) -> Self

Create a new event batcher

pub fn add(&mut self, event: Box<dyn Event>) -> Option<Vec<Box<dyn Event>>>

Add an event to the current batch

pub fn should_flush(&self) -> bool

Check if the batch should be flushed

pub fn flush(&mut self) -> Option<Vec<Box<dyn Event>>>

Flush the current batch and return the events

pub fn current_size(&self) -> usize

Get the current batch size

pub fn is_empty(&self) -> bool

Check if the batch is empty

Trait Implementations

impl Debug for EventBatcher

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

Formats the value using the given formatter.