Skip to main content

AsyncRdfSink

Trait AsyncRdfSink 

Source
pub trait AsyncRdfSink: Send + Sync {
    // Required methods
    fn process_quad(
        &mut self,
        quad: Quad,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + '_>>;
    fn finalize(
        &mut self,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + '_>>;
}
Expand description

Async streaming sink for writing parsed RDF data

Required Methods§

Source

fn process_quad( &mut self, quad: Quad, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + '_>>

Process a parsed quad asynchronously

Source

fn finalize(&mut self) -> Pin<Box<dyn Future<Output = Result<()>> + Send + '_>>

Finalize processing (called when parsing is complete)

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§

Source§

impl AsyncRdfSink for MemoryAsyncSink

Available on crate feature async only.