Treatment concentrate

std/flow/concentrate::concentrate

Generics

◻ T (any)

Configuration

⬡ concentrator: std/flow/concentrate::Concentrator

Inputs

⇥ data: Stream<T>

Receive a Stream<T> and forward each value into the Concentrator channel for type T on the current track.

Pair with concentrated to retrieve the accumulated values after all producers are done.