it is possible with simple pipeline? Without addin...
# coroutinesa
Alexjok
07/14/2019, 8:27 PMit is possible with simple pipeline? Without adding channels and etc
o
octylFractal
07/14/2019, 8:33 PMhttps://github.com/Kotlin/kotlinx.coroutines/issues/1147
specifically for the parallel part. chunking is https://github.com/Kotlin/kotlinx.coroutines/issues/1290
a
Alexjok
07/14/2019, 8:48 PMThx
g
gildor
07/14/2019, 11:22 PMIt's also possible without Flow and Channels
gildor
07/14/2019, 11:24 PMJust chunked, and process each chunk sequentially, do flatMap and inside run 1 coroutine on each item and awaitAll for them
gildor
07/15/2019, 4:16 AMI mean something like this (just change WORKERS_COUNT and check execution time):
https://pl.kotl.in/qjzAuOUmO
👍 1
gildor
07/15/2019, 4:22 AMOr it can be extracted to some more generic function:
https://pl.kotl.in/_tA6hVRRa
👍 2
a
Alexjok
07/15/2019, 7:54 AM@gildor yes, this is what I need! Thx
8 Views