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()withTransformBuilder - Multi-input:
.transform_join()withJoinBuilder
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;