@marcpiechura I understand your point but let's imagine I have this shape that enrich incoming data using settings:
FanInShape2<Settings, Data, EnrichedDataBasedOnSettings>
And I create many of them to run them in parallel, because the enrichment of data takes some time.
I Broadcast Settings to each instance, and I Balance the Data.
At the begining of the test I send a lot of Settings, but nothing comes out, as I only receive data when there a Data coming in.
When I'm done sending all the settings I would like to have a way to say: "Fine, every instance has received its settings, start sending the data"
And that's for test. In real life we don't have this problem, or if data comes before the settings, that's too bad but we don't care.