Struct StreamingPreprocessedParser 

pub struct StreamingPreprocessedParser { /* private fields */ }

A parser with preprocessing for a streaming preprocessor

Implementations

impl StreamingPreprocessedParser

pub fn new(preprocessor: Box<dyn Preprocessor>, parser: Box<dyn Parser>) -> Self

Trait Implementations

impl Parser for StreamingPreprocessedParser

fn parse( &mut self, data: &[u8], metadata: Option<ConnectorMetadata>, ) -> (Option<Box<dyn InputBuffer>>, Vec<ParseError>)

Parses data into records and returns the records and any parse errors that occurred.

fn stage(&self, buffers: Vec<Box<dyn InputBuffer>>) -> Box<dyn StagedBuffers>

Stages all of the buffers, which must have been obtained from this Parser or one forked from this one, into a StagedBuffers that may later be used to push the collected data into the circuit. See StagedBuffers for more information.

fn splitter(&self) -> Box<dyn Splitter>

Returns an object that can be used to break a stream of incoming data into complete records to pass to Parser::parse.

fn fork(&self) -> Box<dyn Parser>

Create a new parser with the same configuration as self.