Struct BatchQueue 

pub struct BatchQueue { /* private fields */ }

A thread-safe batch queue for score events.

Buffers ScoreBody items until the queue reaches max_size, at which point push signals that a flush is needed.

Implementations

impl BatchQueue

pub fn new(max_size: usize) -> Self

Create a new BatchQueue with the given maximum buffer size.

pub fn push(&self, score: ScoreBody) -> bool

Add a score to the queue.

Returns true if the queue has reached max_size (flush needed).

pub fn drain(&self) -> Vec<ScoreBody>

Drain all buffered scores, returning them and leaving the buffer empty.

pub fn len(&self) -> usize

Number of buffered scores.

pub fn is_empty(&self) -> bool

Returns true if the buffer is empty.