I'm starting with flows (and coroutines). I'm trying to create a consumer of a flow that asynchronously executes a function. Would this approach work?
https://pastebin.com/k00hWppm I still have some questions like:
1. Should the map of flows and the executor be in the same scope?
2. Would this scale? For example if i publish hundreds of thousands of "events" in the flows, would this become a problem as I'm launching many coroutines?
As context this is for a load testing library that I'm playing around with