Kotlin协程flow发送时间间隔debounce

青旅半醒 2023-10-15 11:01 17阅读 0赞

### Kotlin协程flow发送时间间隔debounce ###

debounce的作用是让连续发射的数据之间间隔起来。典型的应用场景是搜索引擎里面的关键词输入，当用户输入字符时候，有时候，并不希望用户每输入任何一个单字就触发一次后台真正的查询，而是希望用户在输入一定时间间隔后（猜测此时用户已完成完整关键词的输入），才真正发送最后一次的输入。debounce蕴含了一定的缓冲思想，即，不立刻触发事件，而是先把要发射的数据进入队列，稍等一定时间（时间）延迟触发，而触发的重要条件取决于前一条数据和后一条数据的时间间隔，注意，前一条和后一条尚未被发射出去，只是待命中。如果连续两次间隔时间满足timeOut，只保留最后一条数据。

import kotlinx.coroutines.delay
    import kotlinx.coroutines.flow.*
    import kotlinx.coroutines.runBlocking
    
    fun main(args: Array<String>) {
        val timeOut = 100L
    
        runBlocking {
            val result = userInput()
                .debounce(timeOut).collect {
                    println(it)
                }
        }
    }
    
    fun userInput() = flow {
        emit("A")
        delay(100)
        emit("AB")
        delay(150)
        emit("ABC")
        delay(200)
        emit("ABCD")
        delay(100)
        emit("ABCDE")
    }

当timeOut=100

> AB  
> ABC  
> ABCD  
> ABCDE

A和AB都待发射，A和AB间隔100，所以跳过A，直接发射AB。

发射完AB后，由于ABC与之前的AB间隔超过100，继续发射。

当timeOut=150，比较难理解。

> AB  
> ABC  
> ABCDE

A待发射，Kotlin发现A与AB间隔才100，所以舍弃A，Kotlin发现从A开始到AB之后的ABC，AB的等待时间超过150，且之前的A没有发射，所以发射AB。

发射完AB，下一个ABC与AB之间间隔150，且ABC与其后仍有时间间隔，继续发射ABC。

发射完ABC，Kotlin审视待发射的ABCD，按理说ABCD与ABC间隔200，满足发射timeOut值，但是ABCD与ABCDE间隔100，所以跳过ABCD，直接发射ABCDE。这里特别注意，Kotlin发射当前数据时候，是要把这条数据的前一条、后一条都拉通看的。

当timeOut=200

> ABC  
> ABCDE

A与AB间隔100，舍弃A。而AB与之前的A间隔100，与之后的ABC间隔150，小于timeOut值，舍弃。ABC与之前的AB有时间间隔，与之后的ABCD间隔刚好等于timeOut值，所以发射。

当timeOut=250

> ABCDE

简单的说，Kotlin用debounce发射当前数据时候，这个数据的前一条数据和后一条数据必须满足时间间隔才能发射，否则舍弃。

[Kotlin协程flow，firstOrNull只要最先first，lastOrNull只要最后\_zhangphil的博客-CSDN博客firstOrNull() //虽然发射很多数据，但只要第1次发射过来的数据。.lastOrNull() //虽然发射很多数据，但只要最后1次发射过来的数据。emit(i)delay(10)kotlin协程flow任务意外结束未emit数据retryWhen onEmpty（5）\_zhangphil的博客-CSDN博客一、flow ,emit,onCompletion,collect。![favicon32.ico][]https://blog.csdn.net/zhangphil/article/details/132492588][Kotlin_flow_firstOrNull_first_lastOrNull_zhangphil_-CSDN_firstOrNull_ _1_.lastOrNull_ _1_emit_i_delay_10_kotlin_flow_emit_retryWhen onEmpty_5_zhangphil_-CSDN_flow _emit_onCompletion_collect_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_132492588][kotlin协程flow filter map flowOn zip combine（1）\_zhangphil的博客-CSDN博客一、flow ,emit,onCompletion,collect。四、map，重组改写数据。八、conflate 合并。九、debounce去重。二、函数作为flow。![favicon32.ico][]https://blog.csdn.net/zhangphil/article/details/130084723][kotlin_flow filter map flowOn zip combine_1_zhangphil_-CSDN_flow _emit_onCompletion_collect_map_conflate _debounce_flow_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_130084723]

[favicon32.ico]: https://g.csdnimg.cn/static/logo/favicon32.ico
[Kotlin_flow_firstOrNull_first_lastOrNull_zhangphil_-CSDN_firstOrNull_ _1_.lastOrNull_ _1_emit_i_delay_10_kotlin_flow_emit_retryWhen onEmpty_5_zhangphil_-CSDN_flow _emit_onCompletion_collect_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_132492588]: https://blog.csdn.net/zhangphil/article/details/132492588
[kotlin_flow filter map flowOn zip combine_1_zhangphil_-CSDN_flow _emit_onCompletion_collect_map_conflate _debounce_flow_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_130084723]: https://blog.csdn.net/zhangphil/article/details/130084723