Struct StreamBuffer 

pub struct StreamBuffer { /* private fields */ }

Bounded queue of StreamEvents with backpressure support.

Implementations

impl StreamBuffer

pub fn new(max_size: usize) -> Self

Create a new buffer with the given capacity.

pub fn push(&mut self, event: StreamEvent) -> bool

Push an event into the buffer.

Returns false (backpressure) if the buffer is already full.

pub fn pop(&mut self) -> Option<StreamEvent>

Pop the oldest event from the buffer.

pub fn drain_tokens(&mut self) -> String

Concatenate and remove all StreamEvent::Token events, returning the result.

pub fn is_full(&self) -> bool

Returns true if the buffer has reached its maximum size.

pub fn len(&self) -> usize

Number of events currently in the buffer.

pub fn is_empty(&self) -> bool

Returns true if the buffer contains no events.

pub fn total_received(&self) -> usize

Total number of events ever pushed (including dropped ones).