Struct AsyncStreamingParser 

pub struct AsyncStreamingParser<R: AsyncBufRead + Unpin> { /* private fields */ }

Available on crate feature async-tokio only.

Async streaming parser for processing large files

Implementations

impl<R: AsyncRead + Unpin + Send> AsyncStreamingParser<BufReader<R>>

pub fn new(reader: R) -> Self

Create a new async streaming parser

pub fn with_batch_size(reader: R, batch_size: usize) -> Self

Create a streaming parser with a specific batch size

impl<R: AsyncBufRead + Unpin> AsyncStreamingParser<R>

pub fn from_buf_reader(reader: R, batch_size: usize) -> Self

Create from an existing async 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 async fn next_batch_async(&mut self) -> TurtleResult<Option<Vec<Triple>>>

Parse the next batch of triples asynchronously

pub async fn stream_with_callback<F>( &mut self, callback: F, ) -> TurtleResult<usize>

where F: FnMut(Vec<Triple>),

Stream all triples with a callback

pub async fn collect_all_async(&mut self) -> TurtleResult<Vec<Triple>>

Collect all triples into a vector