Module operators 

Higher-level stream operators (map, filter, fan-out, windowing, etc.).

Modules

combine

Stream combining operators: merge and concat.

concurrent

Concurrent processing operators: rparallel and rfan_out.

rate

Trailing-edge rate-limiting operators: rdebounce, rdebounce_batch, rthrottle. Trailing-edge rate-limiting operators.

transform

Transformation operators: rmap, rfilter, rtap, and rreduce.

windowing

Leading-edge windowing operators: rbatch, rsliding_window, rtumbling_window. Leading-edge windowing and batching operators.