Skip to main content

AsyncRdfSerializer

oxirs_core::io::async_streaming

Trait AsyncRdfSerializer 

Source 
pub trait AsyncRdfSerializer: Send + Sync {
    // Required methods
    fn serialize_quads_async<'a, W, I>(
        &'a self,
        writer: W,
        quads: I,
        config: AsyncStreamingConfig,
        progress: Option<ProgressCallback>,
        cancel_token: Option<Arc<AtomicBool>>,
    ) -> BoxFuture<'a, Result<()>>
       where W: AsyncWrite + Unpin + Send + 'a,
             I: Iterator<Item = Quad> + Send + 'a;
    fn serialize_triples_async<'a, W, I>(
        &'a self,
        writer: W,
        triples: I,
        config: AsyncStreamingConfig,
        progress: Option<ProgressCallback>,
        cancel_token: Option<Arc<AtomicBool>>,
    ) -> BoxFuture<'a, Result<()>>
       where W: AsyncWrite + Unpin + Send + 'a,
             I: Iterator<Item = Triple> + Send + 'a;
}
Expand description

Trait for async RDF serialization with streaming output

Required Methods§

Source

fn serialize_quads_async<'a, W, I>( &'a self, writer: W, quads: I, config: AsyncStreamingConfig, progress: Option<ProgressCallback>, cancel_token: Option<Arc<AtomicBool>>, ) -> BoxFuture<'a, Result<()>>
where W: AsyncWrite + Unpin + Send + 'a, I: Iterator<Item = Quad> + Send + 'a,

Serialize quads to an async writer

Source

fn serialize_triples_async<'a, W, I>( &'a self, writer: W, triples: I, config: AsyncStreamingConfig, progress: Option<ProgressCallback>, cancel_token: Option<Arc<AtomicBool>>, ) -> BoxFuture<'a, Result<()>>
where W: AsyncWrite + Unpin + Send + 'a, I: Iterator<Item = Triple> + Send + 'a,

Serialize triples to an async writer

Dyn Compatibility§

This trait is not dyn compatible.

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

Implementors§