Struct StreamingParser 

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

Streaming parser that yields batches of triples

Implementations

impl<R: Read> StreamingParser<BufReader<R>>

pub fn new(reader: R) -> Self

Create a new streaming parser from a reader

pub fn with_config(reader: R, config: StreamingConfig) -> Self

Create a streaming parser with custom configuration

impl<R: BufRead> StreamingParser<R>

pub fn from_buf_reader(reader: R, config: StreamingConfig) -> Self

Create from an existing BufRead

pub fn triples_parsed(&self) -> usize

Get the number of triples parsed so far

pub fn bytes_read(&self) -> usize

Get the number of bytes read so far

pub fn next_batch(&mut self) -> TurtleResult<Option<Vec<Triple>>>

Parse the next batch of triples

pub fn batches(self) -> StreamingBatchIterator<R>

Get an iterator over batches

pub fn triples(self) -> StreamingTripleIterator<R>

Get an iterator over individual triples