Struct DecoderHandle 

pub struct DecoderHandle { /* private fields */ }

Cloneable telemetry and control handle for a running crate::DecoderReader.

The handle remains usable after the reader has moved into another component such as a FASTQ parser. Cloning a handle does not create decoder workers.

Implementations

impl DecoderHandle

pub fn stats(&self) -> DecoderStats

Returns an approximate lock-free snapshot of decoder activity.

pub fn set_worker_limit(&self, workers: usize) -> Result<(), WorkerLimitError>

Changes the maximum number of decoder workers that may accept work.

The method is nonblocking. Workers already executing a task finish it and publish any completed result they own before retiring. A worker whose bounded result handoff is blocked therefore remains live until output advances or the decode is cancelled. Raising the limit allows the coordinator to create replacement workers lazily when useful work is available.

Errors

Returns WorkerLimitError when workers is zero or exceeds the immutable worker budget supplied to crate::DecoderBuilder.

Trait Implementations

impl Clone for DecoderHandle

fn clone(&self) -> DecoderHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DecoderHandle

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

Formats the value using the given formatter.