Struct ParallelStreamingParser 

pub struct ParallelStreamingParser<R: Read + Send + Sync> { /* private fields */ }

Available on crate feature parallel only.

Parallel streaming parser for processing large files without loading entirely into memory

Implementations

impl<R: Read + Send + Sync + 'static> ParallelStreamingParser<R>

pub fn new(reader: R) -> Self

Create a new parallel streaming parser

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

Create a parallel streaming parser with custom configuration

pub fn process_batches<F>(&mut self, processor: F) -> TurtleResult<usize>

where F: FnMut(Vec<Triple>) + Send,

Process the file in parallel batches

This reads batches from the file and processes them in parallel.