hi everyone, why if I convert flow to a rendezvous channel (I need it for custom operator) and colle...

# coroutines

[bezrukov]

hi everyone, why if I convert flow to a rendezvous channel (I need it for custom operator) and collect it, unnecessary dispatch (between collecting 1 and 2.) is performed. Is there a way to fix this?

val flow = flowOf(1, 2)
produce(capacity = 0) { flow.collect { send(it) } }.consumeAsFlow()
   .onEach { println("each $it") }
   .launchIn(this)

I would expect there will be no difference comparing with:

val flow = flowOf(1, 2)
flow.onEach { println("each $it") }
   .launchIn(this)

Link demonstrates unnecessary redispatch: https://pl.kotl.in/LbbXNwWzU

[gildor]

Produce starts a new coroutine under the hood, so it's already not the same