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)

Implementors§

Source§

impl AsyncRdfSink for MemoryAsyncSink

Available on crate feature async only.