Is there a convenient way to make a `channelFlow` ...

# coroutines

[Lilly]

Is there a convenient way to make a channelFlow hot? I would like to open a stream but defer the collecting. What I'm currently doing:

// cold
fun readByteArrayStream(): Flow<ByteArray> = channelFlow { .. }

// hot
val bytesChannel: Channel<ByteArray> by lazy { Channel(Channel.UNLIMITED) }

suspend fun openByteArrayStream() {
        readByteArrayStream().onEach { bytesChannel.trySend(it) }.collect()
    }

[Adam Powell]

.produceIn?

[Lilly]

Cool, looks good. The coroutines/flow API is so huge, wasn't aware of this method. Thanks boss!