rskit-stream 0.2.0-alpha.2

Foundational async stream toolkit: bounded fan-out broadcaster, sources, cancellable tasks, and futures::Stream extension operators
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12

/// Shared accumulation-buffer helpers for `windowing` and `rate`.
mod buffer;
/// Stream combining operators: `merge` and `concat`.
pub mod combine;
/// Concurrent processing operators: `rparallel` and `rfan_out`.
pub mod concurrent;
/// Trailing-edge rate-limiting operators: `rdebounce`, `rdebounce_batch`, `rthrottle`.
pub mod rate;
/// Transformation operators: `rmap`, `rfilter`, `rtap`, and `rreduce`.
pub mod transform;
/// Leading-edge windowing operators: `rbatch`, `rsliding_window`, `rtumbling_window`.
pub mod windowing;