Struct AsyncStreamingSerializer 

pub struct AsyncStreamingSerializer { /* private fields */ }

Async streaming serializer implementation

Implementations

impl AsyncStreamingSerializer

pub fn new(format: RdfFormat) -> Self

Create a new async streaming serializer

Trait Implementations

impl AsyncRdfSerializer for AsyncStreamingSerializer

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

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