Struct EncodedWriter 

pub struct EncodedWriter<W, E> { /* private fields */ }

Available on crate features quic and std only.

Combine an asynchronous writer with a streaming encoder. The writer is used directly; supply an AsyncWrite buffer when small writes are costly. Finishing writes encoder trailers, flushes, then shuts down the writer, even on errors. Cancellation while the encoder writes trailers cannot be retried; drop the output. Cancellation during writer flush or shutdown resumes that phase. Successful finishes are idempotent.

Implementations

impl<W, E> EncodedWriter<W, E>

pub fn new(writer: W, encoder: E) -> EncodedWriter<W, E>

Pair a destination and encoder; initialization occurs when recording starts.

Trait Implementations

impl<W, E> QlogOutput for EncodedWriter<W, E>

where W: AsyncWrite + Unpin + Send + 'static, E: QlogEncoder + 'static,

async fn begin(&mut self, info: &TraceInfo) -> Result<(), Error>

Initialize output once, before processing events or flush requests.

async fn event(&mut self, event: &QlogEventView<'_>) -> Result<(), Error>

Write one observation in admission order; an error terminates recording.

async fn flush(&mut self) -> Result<(), Error>

Flush buffered output after all earlier admitted commands.

async fn finish(&mut self) -> Result<(), Error>

Finalize output after draining accepted events. Defaults to flushing.