Treatment concentrated

std/flow/concentrate::concentrated

Generics

◻ T (any)

Configuration

⬡ concentrator: std/flow/concentrate::Concentrator

Inputs

⇥ trigger: Block<T>

Outputs

↦ data: Stream<T>

Wait for trigger then drain the Concentrator channel for type T on the current track, re-emitting all accumulated values through data.

trigger must carry a value of the same type T as the accumulated data; the value itself is ignored — only its arrival matters.