Struct NonBlockingWriter 

pub struct NonBlockingWriter { /* private fields */ }

Wraps a MakeWriter with a background thread + bounded mpsc::SyncSender channel. Overflow drops the line and increments the dropped counter. Spec 20 § 3.5.

Implementations

impl NonBlockingWriter

pub fn new<M>(inner: M, capacity: usize) -> (NonBlockingWriter, WorkerGuard)

where M: MakeWriter,

Wrap inner with a background thread. Returns the non-blocking writer and a WorkerGuard whose Drop flushes + joins.

pub fn dropped_total(&self) -> u64

Total bytes dropped due to channel pressure.

Trait Implementations

impl Clone for NonBlockingWriter

fn clone(&self) -> NonBlockingWriter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for NonBlockingWriter

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl MakeWriter for NonBlockingWriter

type Writer = NonBlockingHandle

The writer type produced by Self::make_writer; usually Stdout, Stderr, or a guard around a file handle.

fn make_writer(&self) -> NonBlockingHandle

Yield a writer for this batch.

fn make_writer_for(&self, _sev: Severity) -> Self::Writer

Yield a severity-specific writer; defaults to Self::make_writer.