Alexjok
06/15/2019, 10:33 AMtseisel
06/16/2019, 9:48 AMFlow
in your code is the way input data is generated : https://pl.kotl.in/z0ms0AL48
There is no parallelMap
operator that I am aware of, that allows to distribute the map
operation to a given number of workers. For that part, you still need to use `Channel`s.Dispatchers.Default
as a context of launchProcessor
, so that creating 50 workers makes much more sense than with the single-threaded context of RunBlocking
Alexjok
06/17/2019, 1:39 PM