Tristan Caron
03/27/2018, 3:01 PMlouiscad
03/27/2018, 3:10 PMreturn@consumeEach
Tristan Caron
03/27/2018, 3:16 PMuhe
03/27/2018, 3:19 PMclose
or cancelling the producer) or cancel the consuming coroutineTristan Caron
03/27/2018, 3:27 PMlaunch(job) { // ... consumer }
job.cancel()
elizarov
03/27/2018, 8:07 PMTristan Caron
03/28/2018, 9:01 AMfun 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")
}