fun main(args: Array<String>) {
  val a = ConflatedBroadcastChannel<String>()
  val receiveChannel = a.openSubscription()
  val job = launch {
    receiveChannel.consumeEach {
      println(it)
    }
    receiveChannel.cancel()
  }

  a.offer("a")
  job.cancel()
  a.offer("c")

  Thread.sleep(1000)
}