Struct StreamingParser 

pub struct StreamingParser<R: BufRead> { /* private fields */ }

Streaming parser for memory-efficient processing

Implementations

impl<R: BufRead> StreamingParser<R>

pub fn new(reader: R, version: ERNVersion) -> Self

pub fn with_progress_callback<F>(self, callback: F) -> Self

where F: FnMut(ParseProgress) + Send + 'static,

pub fn with_chunk_size(self, size: usize) -> Self

pub fn with_max_memory(self, max: usize) -> Self

pub fn parse_header(&mut self) -> Result<MessageHeader, ParseError>

Parse the message header

pub fn stream_releases(&mut self) -> ReleaseIterator<'_, R>

Stream releases one at a time for memory efficiency

pub fn stream_resources(&mut self) -> ResourceIterator<'_, R>

Stream resources one at a time

pub fn stream_parties(&mut self) -> PartyIterator<'_, R>

Stream parties

pub fn stream_deals(&mut self) -> DealIterator<'_, R>

Stream deals