Conflated BroadcastChannel

conflated_channel.kt

fun main() = runBlocking<Unit> {
    val channel = ConflatedBroadcastChannel<Int>()

    launch {
        channel.consumeEach {
            println("first: $it")
            delay(500)
        }
    }

    launch {
        channel.consumeEach {
            println("second: $it")
            delay(300)
        }
    }

    for (i in 1..10) {
        delay(100)
        channel.send(i)
    }

    launch {
        channel.consumeEach {
            println("-->later: $it")
        }
    }
}
//console output
first: 1
second: 1
second: 3
first: 5
second: 6
second: 9
-->later: 10
first: 10
second: 10