coroutine BroadcastChannel playground for scratch file

coroutine_broadcastchannel_playground.kt

import kotlinx.coroutines.*
import kotlinx.coroutines.channels.BroadcastChannel
import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.channels.consumeEach


runBlocking {
    val sendChannel = BroadcastChannel<Int>(4)

    println("Starting")

    val job1 = launch(Dispatchers.IO) {
        println("producer: In producer coroutine")
        for (i in 0..10) {
            println("producer: offering $i")
            val offerResult = sendChannel.offer(i)
            if (!offerResult) {
                println("producer: Channel buffer is full. Dropping data $i")
            }
//            val offerResult = sendChannel.send(i)
            println("producer: offer result: $offerResult")
            delay(100)
        }
        sendChannel.close()
    }


    val job2 = launch(Dispatchers.IO) {
        println("consumer 1: In consumer coroutine")
        val delayToConsume = 400L
        delay(delayToConsume)
        println("consumer 1: start consuming after $delayToConsume ms")
        for (msg in sendChannel.openSubscription()){
            println("consumer 1: consuming $msg")
        }
    }

    val job3 = launch(Dispatchers.IO) {
        println("consumer 2: In consumer coroutine")
        val delayToConsume = 300L
        delay(delayToConsume)
        val duration = 300L
        withTimeout(duration){
            println("consumer 2: start consuming after $delayToConsume ms for duration of $duration ms")
            for (msg in sendChannel.openSubscription()){
                println("consumer 2: consuming $msg")
            }
        }
    }

    job1.join()
    job2.join()
    job3.join()
}