简介
今天我们要实现一个功能，批量上传，当用户完成某个动作后就记录下操作数据，然后延迟2秒上传，当2秒内有新的上传任务的时候，就取消上个任务，重新开始计时延时上传，这个行为和Js的防抖功能一样，那么Kotlin如何实现呢？
知道高阶函数的我们可以使用高阶函数和闭包来实现，不知道的请自行学习。
实现
/**
* 消抖行为
*
*/
fun debounceSuspend(delayMs: Long = 500L, coroutineScope: CoroutineScope, f: suspend CoroutineScope.() -> Unit): () -> Unit {
var job: Job? = null
return {
job?.cancel()
job = coroutineScope.launch {
delay(delayMs)
job = null
f()
}
}
}
/**
* 主线程的消抖行为
*/
fun <T> debounceOnMainThread(delayMs: Long = 500L, callback: (T) -> Unit): (T) -> Unit {
val handle = Handler(Looper.getMainLooper())
var runnable: Runnable? = null
return {t->
runnable?.let {
handle.removeCallbacks(it)
}
runnable = Runnable {
callback(t)
}
handle.postDelayed(runnable, delayMs)
}
}
可以看到，异步和主线程的防抖实现都是返回一个匿名函数，外部每次调用匿名函数的时候，都会先取消上次的行为，然后延迟一段时间，执行任务。
调用方式如下
private val debounceWifiChanged = debounceOnMainThread<Boolean>(5000) {
onWifiConnectedChange(it)
}
当高层监听到变化都调用一次debounceWifiChanged函数。
