Struct StreamingParser 

pub struct StreamingParser { /* private fields */ }

An incremental Turtle parser that accepts chunks of text.

Implementations

impl StreamingParser

pub fn new() -> Self

Create a new parser with no base IRI.

pub fn with_base(base_iri: impl Into<String>) -> Self

Create a new parser with a base IRI.

pub fn feed( &mut self, chunk: &str, ) -> Result<Vec<ParsedTriple>, StreamParseError>

Feed a chunk of Turtle text, returning all complete triples parsed.

pub fn flush(&mut self) -> Result<Vec<ParsedTriple>, StreamParseError>

Flush any remaining buffered content, returning any remaining triples.

parse_buffer() (invoked by every feed() call) only ever leaves the internal buffer non-empty in two cases: it is waiting for more input to complete the statement currently being parsed, or it is genuinely empty — any statement that already parses cleanly is consumed and removed from the buffer immediately, and any outright syntax error is already surfaced as an Err from feed() itself. Therefore, if any non-whitespace, non-comment content remains in the buffer once the caller declares the stream finished, that content is by definition an incomplete, truncated statement. Per this project’s fail-loud contract, that must be reported as an error rather than silently discarded as an empty, successful result.

pub fn triples_parsed(&self) -> u64

Return total triples parsed so far.

pub fn prefixes(&self) -> &HashMap<String, String>

Return the current prefix map.

pub fn set_base(&mut self, base: impl Into<String>)

Set the base IRI for relative IRI resolution.

pub fn reset(&mut self)

Reset the parser state.

pub fn parse_complete( input: &str, ) -> Result<Vec<ParsedTriple>, StreamParseError>

Parse a complete Turtle document in one call.

pub fn expand_prefix(&self, prefixed: &str) -> Result<String, StreamParseError>

Expand a prefixed name to a full IRI using current prefix map.

Trait Implementations

impl Default for StreamingParser

fn default() -> Self

Returns the “default value” for a type.