I have a producer as follows: ``` val produce...

# coroutines

[Ian]

I have a producer as follows:

val produceRecommendations = produce {
        while (true) {
            send(rec.recommend())
        }
    }

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 consumeEach within a runBlocking 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