Struct StreamingProcessor 

pub struct StreamingProcessor<R: Read> { /* private fields */ }

Streaming SARIF processor with callback support

This allows processing SARIF files with custom logic applied to each run

Implementations

impl<R: Read> StreamingProcessor<R>

pub fn new(reader: R) -> Self

Create a new streaming processor

pub fn with_memory_limit(self, max_memory_mb: usize) -> Self

Set maximum memory usage limit in MB

pub fn process_with_callback<F>( &mut self, callback: F, ) -> ParseResult<StreamingStats>

where F: FnMut(&Run, &SarifMetadata) -> ParseResult<()>,

Process SARIF file with a callback for each run

pub fn filter_results<F>(&mut self, predicate: F) -> ParseResult<Vec<Result>>

where F: FnMut(&Result) -> bool,

Process and collect all results matching a predicate

pub fn stats(&self) -> &StreamingStats

Get current processing statistics