Struct StreamingProcessor 

pub struct StreamingProcessor { /* private fields */ }

Production streaming processor with bounded memory

Implementations

impl StreamingProcessor

pub fn new(threshold_bps: u32) -> Result<Self, ProcessingError>

Create new production streaming processor

pub fn with_config( threshold_bps: u32, config: StreamingProcessorConfig, ) -> Result<Self, ProcessingError>

Create with custom configuration

pub fn trade_sender(&mut self) -> Option<Sender<AggTrade>>

Get trade sender for external components

pub fn bar_receiver(&mut self) -> Option<Receiver<RangeBar>>

Get bar receiver for external components

pub async fn start_processing(&mut self) -> Result<(), StreamingError>

Start processing loop (bounded memory, infinite capability)

pub fn metrics(&self) -> &StreamingMetrics

Get current metrics

pub fn get_final_incomplete_bar(&mut self) -> Option<RangeBar>

Extract final incomplete bar when stream ends (for algorithmic consistency)

pub fn check_memory_usage(&self) -> bool

Check memory usage against threshold