Keyboard shortcuts

Press or to navigate between chapters

Press S or / to search in the book

Press ? to show this help

Press Esc to hide this help

Model Concentrator

std/flow/concentrate::Concentrator


Collect and re-distribute typed data streams across tracks within a single engine run.

concentrate / concentrateBlock push values in per-track, per-type channels; concentrated drains those channels back out as a stream. Useful when multiple upstream tracks need to fan-in into a single downstream consumer that processes all values after all producers have finished.