Skip to main content

Module transform

Module transform 

Source
Expand description

Reactive transform primitives for derived records.

§Transform Archetypes

  • Map (1:1, stateless): Transform each input value to zero-or-one output value
  • Accumulate (N:1, stateful): Aggregate a stream of values with persistent state
  • Join (M×N:1, stateful, multi-input): Combine values from multiple input records

All three are handled by a unified API surface:

  • Single-input: .transform() with TransformBuilder
  • Multi-input: .transform_join() with JoinBuilder

Re-exports§

pub use single::StatefulTransformBuilder;
pub use single::TransformBuilder;
pub use single::TransformPipeline;
pub use join::JoinBuilder;
pub use join::JoinEventRx;
pub use join::JoinPipeline;
pub use join::JoinTrigger;

Modules§

join
single