Struct BatchEngine 

pub struct BatchEngine { /* private fields */ }

Wraps Engine for concurrent multi-document processing with backpressure.

The underlying Engine is shared via Arc; cloning BatchEngine is cheap.

Implementations

impl BatchEngine

pub fn new(engine: Engine, options: BatchOptions) -> Self

pub fn lint_many( &self, docs: impl IntoIterator<Item = (String, Vec<u8>)>, ) -> impl Stream<Item = (String, Result<LintResult, BatchError>)>

Lint many documents concurrently. Yields (id, Result) in completion order; an Err indicates the per-document task panicked or was cancelled — it does not abort the batch.

pub fn fix_many( &self, docs: impl IntoIterator<Item = (String, Vec<u8>)>, ) -> impl Stream<Item = (String, Result<FixResult, BatchError>)>

Fix many documents concurrently. Yields (id, Result) in completion order; an Err indicates the per-document task panicked or was cancelled — it does not abort the batch.