ReceiveChannel throttle function

throttle.kt

fun <T> ReceiveChannel<T>.throttle(
    settleTime: Long = 300,
    scope: CoroutineScope
): ReceiveChannel<T> = scope.produce {
    var job: Job? = null
    consumeEach {
        job?.cancel()
        job = launch {
            delay(settleTime)
            send(it)
        }
    }
    job?.join() //waiting for the last job to end
}

fun main(args: Array<String>) = runBlocking {
    val channel = produce {
        (0..100).forEach {
            println("send$it")
            send(it)
            delay(Random().nextInt(400).toLong())
        }
    }
    channel.throttle(300, GlobalScope).consumeEach { println("Yay!") }
}