Processing in batches from async events

[michaelb]

Thank you all for your help!

I found good example My GenStage producer runs out of work to do, I buffer demand, but how do I know there is new work? that works for me.