rskit_stream/operators/mod.rs
1/// Shared accumulation-buffer helpers for `windowing` and `rate`.
2mod buffer;
3/// Stream combining operators: `merge` and `concat`.
4pub mod combine;
5/// Concurrent processing operators: `rparallel` and `rfan_out`.
6pub mod concurrent;
7/// Trailing-edge rate-limiting operators: `rdebounce`, `rdebounce_batch`, `rthrottle`.
8pub mod rate;
9/// Transformation operators: `rmap`, `rfilter`, `rtap`, and `rreduce`.
10pub mod transform;
11/// Leading-edge windowing operators: `rbatch`, `rsliding_window`, `rtumbling_window`.
12pub mod windowing;