seo站内优化培训,做前后端网站教程,wordpress数据库删不掉,零基础网络工程师培训Kotlin协程flow发送时间间隔debounce
debounce的作用是让连续发射的数据之间间隔起来。典型的应用场景是搜索引擎里面的关键词输入#xff0c;当用户输入字符时候#xff0c;有时候#xff0c;并不希望用户每输入任何一个单字就触发一次后台真正的查询#xff0c;而是希望…Kotlin协程flow发送时间间隔debounce
debounce的作用是让连续发射的数据之间间隔起来。典型的应用场景是搜索引擎里面的关键词输入当用户输入字符时候有时候并不希望用户每输入任何一个单字就触发一次后台真正的查询而是希望用户在输入一定时间间隔后猜测此时用户已完成完整关键词的输入才真正发送最后一次的输入。debounce蕴含了一定的缓冲思想即不立刻触发事件而是先把要发射的数据进入队列稍等一定时间时间延迟触发而触发的重要条件取决于前一条数据和后一条数据的时间间隔注意前一条和后一条尚未被发射出去只是待命中。如果连续两次间隔时间满足timeOut只保留最后一条数据。 import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.runBlockingfun main(args: ArrayString) {val timeOut 100LrunBlocking {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)
}当timeOut100 AB ABC ABCD ABCDE A和AB都待发射A和AB间隔100所以跳过A直接发射AB。
发射完AB后由于ABC与之前的AB间隔超过100继续发射。 当timeOut150比较难理解。 AB ABC ABCDE A待发射Kotlin发现A与AB间隔才100所以舍弃AKotlin发现从A开始到AB之后的ABCAB的等待时间超过150且之前的A没有发射所以发射AB。
发射完AB下一个ABC与AB之间间隔150且ABC与其后仍有时间间隔继续发射ABC。
发射完ABCKotlin审视待发射的ABCD按理说ABCD与ABC间隔200满足发射timeOut值但是ABCD与ABCDE间隔100所以跳过ABCD直接发射ABCDE。这里特别注意Kotlin发射当前数据时候是要把这条数据的前一条、后一条都拉通看的。 当timeOut200 ABC ABCDE A与AB间隔100舍弃A。而AB与之前的A间隔100与之后的ABC间隔150小于timeOut值舍弃。ABC与之前的AB有时间间隔与之后的ABCD间隔刚好等于timeOut值所以发射。 当timeOut250 ABCDE 简单的说Kotlin用debounce发射当前数据时候这个数据的前一条数据和后一条数据必须满足时间间隔才能发射否则舍弃。 Kotlin协程flowfirstOrNull只要最先firstlastOrNull只要最后_zhangphil的博客-CSDN博客firstOrNull() //虽然发射很多数据但只要第1次发射过来的数据。.lastOrNull() //虽然发射很多数据但只要最后1次发射过来的数据。emit(i)delay(10)kotlin协程flow任务意外结束未emit数据retryWhen onEmpty5_zhangphil的博客-CSDN博客一、flow ,emit,onCompletion,collect。https://blog.csdn.net/zhangphil/article/details/132492588kotlin协程flow filter map flowOn zip combine1_zhangphil的博客-CSDN博客一、flow ,emit,onCompletion,collect。四、map重组改写数据。八、conflate 合并。九、debounce去重。二、函数作为flow。https://blog.csdn.net/zhangphil/article/details/130084723
