Hello. Is there any simple build in extension to r...

# coroutines

[Vlad]

Hello. Is there any simple build in extension to receive values from simple Channel like

channel.consumeEach { }

but not close channel on cancel. consumeEach does not close BroadcastChannel nor ConflatedBroadcastChannel on cancelation. Should i just stick to

for(it in channel){
    
}

and create my own helper extension function?

[octylFractal]

I don't quite get the question, do you want it to close on cancel or not? you said "Is there .... like consumeEach, but does not close on cancel", but also "`consumeEach` does not close on cancel", which makes it sound like you already have what you want

[Vlad]

Example

val channel = Channel<Int>(capacity = 1)
val broadcastChannel = BroadcastChannel<Int>(capacity = 1)

launch { channel.consumeEach { } }.apply {
    delay(100)
    cancel()
}
launch { broadcastChannel.consumeEach { } }.apply {
    delay(100)
    cancel()
}
println("${channel.isClosedForReceive} ${channel.isClosedForReceive}")
println("${broadcastChannel.isClosedForSend}")

output

false false
true

I want it to stay alive and use reuse it sometime later

[octylFractal]

is there something wrong with using the for loop? I think that's basically what you want, and it isn't much longer than a method call

[octylFractal]

this is mentioned in the consumeEach docs as well: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.channels/consume-each.html

[octylFractal]

If you need to iterate over the channel without consuming it, a regular for loop should be used instead.