Struct StreamingProcessor 

pub struct StreamingProcessor { /* private fields */ }

Enhanced streaming processor with performance optimizations

Implementations

impl StreamingProcessor

pub fn new(config: StreamingPerformanceConfig) -> Self

Create a new streaming processor

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

Process a streaming event with performance optimizations

Errors

Returns an error if event processing fails or if buffer operations fail.

pub async fn process_batch( &self, events: Vec<ResponseStreamEvent>, ) -> Result<()>

Process multiple events in a batch

Errors

Returns an error if any event in the batch fails to process.

pub async fn get_buffer_stats(&self) -> StreamingPerformanceStats

Get buffer statistics

pub async fn get_connection_stats(&self) -> ConnectionPoolStats

Get connection pool statistics

pub async fn get_processing_stats(&self) -> ProcessingStats

Get processing statistics

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

Flush all buffered events

Errors

Returns an error if buffer flushing fails or event batch processing encounters issues.

Trait Implementations

impl Debug for StreamingProcessor

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

Formats the value using the given formatter.