Expand description
Processor trait — user-defined handler executed for each decoded update.
§Flow
- A datasource emits an
Updateinto the pipeline. - Matching pipes filter and route the update.
- Each pipe decodes (or forwards) and invokes
Processor::process.
§Notes
- Uses native
impl Future(Rust 1.75+) sinceProcessoris 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.