Take a look at the example that is given in flowViaChannel builder’s documentation: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/flow-via-channel.html UPDATE: It is going to be renamed to channelFlow.