Struct AsyncStreamingParser 

pub struct AsyncStreamingParser { /* private fields */ }

Async streaming parser implementation

Implementations

impl AsyncStreamingParser

pub fn new(format: RdfFormat) -> Self

Create a new async streaming parser

Trait Implementations

impl AsyncRdfParser for AsyncStreamingParser

fn parse_async<'a, R>( &'a self, reader: R, config: AsyncStreamingConfig, progress: Option<ProgressCallback>, cancel_token: Option<Arc<AtomicBool>>, ) -> BoxFuture<'a, Result<Vec<Quad>>>

where R: AsyncRead + Unpin + Send + 'a,

Parse RDF data from an async reader

fn parse_with_handler_async<'a, R, F, Fut>( &'a self, reader: R, handler: F, config: AsyncStreamingConfig, progress: Option<ProgressCallback>, cancel_token: Option<Arc<AtomicBool>>, ) -> BoxFuture<'a, Result<()>>

where R: AsyncRead + Unpin + Send + 'a, F: FnMut(Quad) -> Fut + Send + 'a, Fut: Future<Output = Result<()>> + Send + 'a,

Parse RDF data from an async reader with a custom handler