Struct StreamingBuffer 

pub struct StreamingBuffer { /* private fields */ }

Enhanced streaming buffer with performance optimizations

Implementations

impl StreamingBuffer

pub fn new(config: StreamingPerformanceConfig) -> Self

Create a new streaming buffer with configuration

pub async fn push_event(&self, event: ResponseStreamEvent) -> Result<bool>

Add an event to the buffer with performance optimizations

Errors

Returns an error if the event cannot be processed or serialized.

Panics

Panics if the internal mutex for event hashes or buffer size is poisoned.

pub async fn flush_buffer(&self) -> Result<Option<EventBatch>>

Flush the buffer and return batched events

Errors

Returns an error if event compression or serialization fails.

Panics

Panics if the internal mutex for buffer or buffer size is poisoned.

pub async fn get_stats(&self) -> StreamingPerformanceStats

Get current performance statistics

pub async fn reset_stats(&self)

Reset statistics

Trait Implementations

impl Debug for StreamingBuffer

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

Formats the value using the given formatter.