Throttler

Throttler.kt

class Throttler<T>(
    scope: CoroutineScope,
    period: Long
): Debouncer<T>(scope, period) {

    fun throttle(
        arg: T,
        block: suspend CoroutineScope.(T) -> Unit
    ): Boolean {
        synchronized(this@Throttler) {
            if (lastRan + period <= System.currentTimeMillis()) {
                lastRan = System.currentTimeMillis()
                scheduleJob?.cancel()
                scheduleJob = null
                scope.launch { block(arg) }
                return true
            }
        }
        val delay = period - (lastRan % period)
        debounce(arg, delay, block)
        return false
    }
}