Hello, How I can cancel a consumeEach from a chann...

# coroutines

[Tristan Caron]

Hello, How I can cancel a consumeEach from a channel?

[louiscad]

@Tristan Caron By using return@consumeEach

[Tristan Caron]

I mean, to prevent it to consume more

[uhe]

close the channel (by calling close or cancelling the producer) or cancel the consuming coroutine

[uhe]

depends on what you actually wanna do

[Tristan Caron]

Actually, it's a ConflatedBroadcastChannel, I want to avoid to close it. Canceling the coroutine doesn't seem to work

launch(job) { // ... consumer }
job.cancel()

[elizarov]

Can you give, please, a self-contained example of code that does not work when you cancel a job?

[Tristan Caron]

It's working, my bad. I was not cancelling the correct job.
This works

fun main(args: Array<String>) = runBlocking {
    val channel = ConflatedBroadcastChannel<String>()

    val job = launch {
        channel.consumeEach {
            println(it)
        }
    }

    channel.send("This should be printed")

    delay(1000)

    println("Cancelling job")
    job.cancel()

    delay(1000)

    channel.send("This should not be printed")

    delay(1000)

    println("Done")
}