debounce（过滤操作符）

1 debounce：去抖

2 throttle 节流

4 debounce图解说明

5 ebounce测试用例

6 debounce测试用例说明

debounce很有意思的一个词，去抖，要明白debounce的用法首先要知道什么是“去抖”

1 debounce：去抖

当调用函数N秒后，才会执行函数中动作，若在这N秒内又重复调用该函数则将取消前一次调用，并重新计算执行时间。

这个debounce在js常被使用，比如界面根据用户输入做ajax请求局部刷新页面，那么势必会重复请求接口，而实际可能在n秒内用户并没有完成输入，那么频繁调函数肯定是不准确的，那么可以设定一个debounce time，在n秒内的调用都是无效的。

2 throttle 节流

与之相对的是throttle，节流，网络上有个很形象的比喻：如果将水龙头拧紧直到水是以水滴的形式流出，那你会发现每隔一段时间，就会有一滴水流出。

也就是会说预先设定一个执行周期，当调用动作的时刻大于等于执行周期则执行该动作，然后进入下一个新周期。throttle会在后面分析。

3 debounce接口

<U> Flowable<T>

debounce(Function<? super T,? extends Publisher<U>> debounceIndicator)

Returns a Flowable that mirrors the source Publisher, except that it drops items emitted by the source Publisher that are followed by another item within a computed debounce duration.

返回一个镜像源Publisher的Flowable，它会丢弃源Publisher在去抖时间内紧跟着发出的项目（也就是在n秒内会发送多个项目，因为在去抖时间内，将会丢弃）

Flowable<T>

debounce(long timeout, TimeUnit unit)

Returns a Flowable that mirrors the source Publisher, except that it drops items emitted by the source Publisher that are followed by newer items before a timeout value expires.

返回镜像源Publisher的Flowable，但它会丢弃源Publisher发出的项，这些项后面跟着在超时值到期之前新发射的项（简单点说就是，比如超时时间是1s，在1s内Publisher会发射多个值，在这个时间内，最后发射的项才会有效，它前面发射的项目都要被丢弃）

Flowable<T>

debounce(long timeout, TimeUnit unit, Scheduler scheduler)

Returns a Flowable that mirrors the source Publisher, except that it drops items emitted by the source Publisher that are followed by newer items before a timeout value expires on a specified Scheduler.

返回一个镜像源Publisher的Flowable，它在指定的Scheduler上超时值到期之前删除源Publisher发出的后跟更新项的项。

（翻译有些绕口，只要明白什么是debounce这些就不难理解了

4 debounce图解说明

如果特定的时间跨度已经过去而没有发出另一个项目，则只从Observable中发出一个项目

5 ebounce测试用例

@Testpublic void debounce() {System.out.println("######debounce#####");Flowable flowable = Flowable.just("李晓明", "张宝庆","赵无极").debounce(1,TimeUnit.MILLISECONDS);flowable.subscribe(new Consumer<String>() {@Overridepublic void accept(String value) throws Exception {System.out.println("value = " + value);}});}测试结构
######debounce#####
value = 赵无极

6 debounce测试用例说明

上面测试用例为了达到效果特别设置了去抖时间是1ms，也就是说“赵无极”发射时间因为在去抖时间之内，所以其前面发射的项被丢弃掉了，之中只是计算了它（赵无极）。这个操作符需要结合场景来理解，比如说，1秒内有新数据，那么久丢弃旧数据。

其他操作符

delay delaySubscription（辅助操作符）

delaySubscription（辅助操作符）

switchIfEmpty（条件操作符）

debounce（过滤操作符）去重复操作

count（统计操作符）

contains（条件操作符）

concatWith（连接操作符）

concatMap（变换操作符）

collect & collectInto

cast

cache

buffer

RxJava2 Flowable debounce（过滤操作符）去重复操作相关推荐

RxJava2 Flowable filter (过滤操作符)
filter(过滤操作符) 目录 1 filter作用 2 filter接口 3 filter图解说明 4 filter测试用例 1 filter作用通过指定的条件来过滤发布者发出的项. 2 fil ...
Carson带你学Android：RxJava过滤操作符
前言 Rxjava由于其基于事件流的链式调用.逻辑简洁 & 使用简单的特点,深受各大 Android开发者的欢迎. 今天,我将为大家详细介绍RxJava操作符中最常用的过滤操作符,希望你们会 ...
[Android开发] RxJava2之路五 - 过滤操作符例子Demo
一.过滤操作符列表用于过滤和选择Observable发射的数据序列方法含义 filter() 过滤数据 takeLast() 只发射最后的N项数据 last() 只发射最后的一项数据 lastO ...
RxJava2.x使用以及操作符详解
RxJava2.x是一个非常棒的流式编程,采用的观察者模式思想,事件的产生者产生事间之后发送给绑定的接受者,接受顺序与发送顺序一致.但是是独立于RxJava1.x存在,本文讲解RxJava2.x的简 ...
RxJava系列四（过滤操作符）
转载请注明出处:https://zhuanlan.zhihu.com/p/21966621 RxJava系列1(简介) RxJava系列2(基本概念及使用介绍) RxJava系列3(转换操作符) Rx ...
Android RxJava操作符的学习---过滤操作符
3.5 过滤操作符作用过滤 / 筛选被观察者(Observable)发送的事件 & 观察者 (Observer)接收的事件应用场景根据指定条件过滤事件根据指定事件数量过滤事 ...
RxJava从入门到不离不弃（四）——过滤操作符
RxJava中的过滤操作符,顾名思义,这类操作符主要用于对事件数据的筛选过滤,只返回满足我们条件的数据. 我们试想一下这样的一个需求,有一个学生集合,要求将其中成绩不及格的学生过滤,返回成绩合格的学生 ...
解剖 RxJava 之过滤操作符
介绍此文章结合 Github AnalyseRxJava 项目,给 Android 开发者带来 RxJava 详细的解说.参考自 RxJava Essential 及书中的例子关于 RxJava ...
RxJava 过滤操作符（Filtering Observables Operators）
RxJava系列教程: 1. RxJava使用介绍 [视频教程] 2. RxJava操作符 • Creating Observables(Observable的创建操作符) [视频教程] • ...

RxJava2 Flowable debounce（过滤操作符）去重复操作

debounce（过滤操作符）

1 debounce：去抖

2 throttle 节流

4 debounce图解说明

5 ebounce测试用例

6 debounce测试用例说明

RxJava2 Flowable debounce（过滤操作符）去重复操作相关推荐

最新文章

热门文章