Yes, but I cannot do

I’m new to channels but guess something like this?

fun main(args: Array<String>) = runBlocking<Unit> {
  val broadcast = ArrayBroadcastChannel<Int>(10)
  launch(CommonPool) {
    broadcast.consumeEach { i -> println("channel-0:$i") }
  }
  broadcast.offer(1)
  broadcast.offer(2)
  launch(CommonPool) {
    broadcast.consumeEach { i -> println("channel-1:$i") }
  }
  broadcast.offer(3)
  broadcast.offer(4)
  broadcast.close()
}

This is the result

./AppKt
channel-0:2
channel-0:3
channel-0:4

Process finished with exit code 0

I tried this but not doing what I want either.

fun main(args: Array<String>) = runBlocking<Unit> {
    val broadcast = BroadcastChannel<Int>(10)

    launch {
        broadcast.openSubscription().use {
            for (value in it) {
                println(value)
            }
        }
    }

    broadcast.offer(1)
    broadcast.offer(2)

    launch {
        broadcast.openSubscription().use {
            for (value in it) {
                println(value)
            }
        }
    }

    broadcast.offer(3)
    broadcast.offer(4)

}

Sorry. It seems the result depends on the timings. How about this?

fun main(args: Array<String>) = runBlocking<Unit> {
  val broadcast = ArrayBroadcastChannel<Int>(10)
  val job1 = launch(CommonPool) {
    broadcast.consumeEach { i -> println("channel-0:$i") }
  }
  broadcast.offer(1)
  broadcast.offer(2)
  val job2 = launch(CommonPool) {
    broadcast.consumeEach { i -> println("channel-1:$i") }
  }
  broadcast.offer(3)
  broadcast.offer(4)
  broadcast.close()
  job1.join()
  job2.join()
}

It's working thank you. The problem now is when we did offer 10 elements (in this exemple). The channel close automatically. How I can prevent it?

Int.MAX_VALUE

is not a valid answer I think 😛

Well, I have no idea 🙄 I will dig into it.