Struct StreamingParser 

pub struct StreamingParser { /* private fields */ }

Streaming parser for memory-efficient SAMM model processing

Implementations

impl StreamingParser

pub fn new() -> Self

Create a new streaming parser with default settings

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

Set the chunk size for reading (in bytes)

Smaller chunks use less memory but may be slower. Larger chunks are faster but use more memory.

Default: 64KB

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

Set the maximum buffer size (in bytes)

When the buffer grows beyond this size, the parser will attempt to flush and parse accumulated data.

Default: 16MB

pub fn with_base_uri(self, base_uri: impl Into<String>) -> Self

Set the base URI for resolving relative references

pub async fn parse_file_streaming<P: AsRef<Path>>( &mut self, path: P, ) -> Result<impl Stream<Item = Result<Aspect>>>

Parse a file using streaming for memory efficiency

This method reads the file in chunks and emits parsed Aspect models as they become available. This is much more memory-efficient than loading the entire file at once.

Arguments

• path - Path to the Turtle file

Returns

A stream of Result<Aspect, SammError> that emits aspects as they’re parsed

pub fn parse_reader_streaming<R>( &mut self, reader: R, base_uri: impl Into<String>, ) -> impl Stream<Item = Result<Aspect>>

where R: AsyncReadExt + Unpin + Send + 'static,

Parse from an async reader using streaming

This allows streaming from any async source (file, network, etc.)

pub fn parse_string_streaming( &self, content: String, base_uri: impl Into<String>, ) -> impl Stream<Item = Result<Aspect>>

Parse a string using line-by-line streaming

This is useful for processing large in-memory strings without creating multiple copies.

pub fn config_summary(&self) -> String

Get current configuration as a summary string

Trait Implementations

impl Default for StreamingParser

fn default() -> Self

Returns the “default value” for a type.