Struct BatchTransformer 

pub struct BatchTransformer {
    pub size: usize,
    /* private fields */
}

Transformer that batches events by accumulation.

Accumulates stream data values until size items are collected, then emits them as a single JSON array. This reduces overhead for high-volume token streaming by coalescing small chunks into fewer deliveries.

Use flush() to retrieve any remaining buffered items before the transformer is dropped.

Fields

size: usize

Maximum number of items to accumulate before emitting a batch.

Implementations

impl BatchTransformer

pub fn new(size: usize) -> Self

Create a new BatchTransformer with the given batch size.

A size of 0 is clamped to 1 to ensure forward progress.

pub fn flush(&self) -> Option<Value>

Flush all buffered items as a JSON array.

Returns None if the buffer is empty.

Panics

Panics if the internal mutex is poisoned (i.e., another thread panicked while holding the lock).

Trait Implementations

impl Clone for BatchTransformer

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BatchTransformer

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

Formats the value using the given formatter.

impl StreamTransformer for BatchTransformer

fn transform(&self, data: Value) -> Option<Value>

Transform the data.