I have a producer as follows: ``` val produce...
# coroutines
I have a producer as follows:
Copy code
val produceRecommendations = produce {
        while (true) {
I then consume the output of that using another
produce {}
block, and it does some time consuming processing on it before passing it along to another consumer which prints the result. I’m using a
within a
to consume these, but this just appears to use a single core. How can I paralyze this over multiple cores? Mostly it is the second step that needs to be parallelized. Here is the rest of the code: https://gist.github.com/sanity/0cd79558c40736384e12636bf63ce313