Struct AsyncDispatcher 

pub struct AsyncDispatcher { /* private fields */ }

A dispatcher that offloads log processing to a background thread.

Implementations

impl AsyncDispatcher

pub fn new( dispatcher: Box<dyn Dispatcher + Send + Sync>, buffer_size: usize, ) -> Self

Creates a new AsyncDispatcher that wraps the provided dispatcher.

This constructor spawns a dedicated background thread that manages log dispatching. All log records sent to this dispatcher are queued in an internal bounded channel before being processed asynchronously.

Arguments

• dispatcher - The underlying Dispatcher responsible for the actual output (e.g., writing to a file or standard streams).
• buffer_size - The maximum capacity of the internal channel. When the buffer is full, logging threads will block until space becomes available (backpressure).

Panics

This method will panic if the operating system fails to spawn the background OS thread.

Example

use cirious_codex_logger::{AsyncDispatcher, StdoutDispatcher, StyledTerminalFormatter};

let stdout_dispatcher = Box::new(StdoutDispatcher::new(StyledTerminalFormatter));
let async_dispatcher = AsyncDispatcher::new(stdout_dispatcher, 1024);

Examples found in repository

examples/async_logging.rs (line 11)

fn main() {
  let stdout = Box::new(StdoutDispatcher::new(StyledTerminalFormatter));
  let async_dispatcher = Box::new(AsyncDispatcher::new(stdout, 100));

  init(async_dispatcher).ok();

  warn!("This log is processed in a background thread without blocking.");
}

Trait Implementations

impl Debug for AsyncDispatcher

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

Formats the value using the given formatter.

impl Dispatcher for AsyncDispatcher

fn dispatch(&self, record: &Record) -> DispatchResult

Dispatches a log record to the underlying destination.