I have a list of flows, and I want each flow to be processed concurrently in a separate coroutine for its transformations. Finally, I need to merge all flows into a single flow for downstream consumers.
What is the most straightforward way to achieve this. My idea is to launch coroutines for each flow and collect them, and publish to a channel from the different coroutines. and receive as flow