Skip to main content

Module processor

Module processor 

Source
Expand description

Processor trait — user-defined handler executed for each decoded update.

§Flow

  1. A datasource emits an Update into the pipeline.
  2. Matching pipes filter and route the update.
  3. Each pipe decodes (or forwards) and invokes Processor::process.

§Notes

  • Uses native impl Future (Rust 1.75+) since Processor is always used as a generic bound, avoiding per-call boxing.
  • Dyn-dispatched traits in the crate (Datasource, *Pipes) retain #[async_trait] due to current async trait object limitations.

Traits§

Processor
Async handler invoked for each decoded update of type T.