block1.kotlin

suspend fun channelsExample() {

        val numbersStream: Channel<Integer> = Channel(Channel.CONFLATED)


        for (value in numbersStream) {
            println("value updated :")
            println(value)
        }

        numbersStream.offer(1)
        numbersStream.offer(2)
        numbersStream.offer(3)

        val lastNumber = numbersStream.poll()

        println(lastNumber)
    }