RxJava过滤操作符 debounce

debounce操作符是对源Observable间隔期产生的结果进行过滤，如果在这个规定的间隔期内没有别的结果产生，则将这个结果提交给订阅者，否则忽略该结果，原理有点像光学防抖.

.debounce(时间，时间单位)

例子:

 Observable.create(new Observable.OnSubscribe<Integer>() {@Overridepublic void call(Subscriber<? super Integer> subscriber) {if (subscriber.isUnsubscribed()) return;try {for (int i = 0; i < 10; i++) {subscriber.onNext(i);try {Thread.currentThread().sleep(i * 1000);} catch (InterruptedException e) {e.printStackTrace();}}subscriber.onCompleted();} catch (Exception e) {subscriber.onError(e);}}}).subscribeOn(Schedulers.newThread()).debounce(5, TimeUnit.SECONDS).subscribe(new Action1<Integer>() {@Overridepublic void call(Integer integer) {LogUtils.d("------->call():" + integer);}});

结果为:

03-01 10:01:15.040 3591-3736/com.rxandroid.test1 D/----->: ------->call():5
03-01 10:01:20.030 3591-3736/com.rxandroid.test1 D/----->: ------->call():6
03-01 10:01:26.030 3591-3736/com.rxandroid.test1 D/----->: ------->call():7
03-01 10:01:33.030 3591-3736/com.rxandroid.test1 D/----->: ------->call():8
03-01 10:01:41.030 3591-3736/com.rxandroid.test1 D/----->: ------->call():9

在这里间隔期定义为5s,很显然第一个5秒期间产生了不止一个数据，所以都会舍弃,从第5个数据开始，每个间隔期只产生了唯一的一个数据，这回提交给订阅者

RxJava过滤操作符 debounce相关推荐

Carson带你学Android：RxJava过滤操作符
前言 Rxjava由于其基于事件流的链式调用.逻辑简洁 & 使用简单的特点,深受各大 Android开发者的欢迎. 今天,我将为大家详细介绍RxJava操作符中最常用的过滤操作符,希望你们会 ...
RxJava 过滤操作符（Filtering Observables Operators）
RxJava系列教程: 1. RxJava使用介绍 [视频教程] 2. RxJava操作符 • Creating Observables(Observable的创建操作符) [视频教程] • ...
RxJava过滤操作符
概述过滤操作符用于过滤和选择Observable发射的数据序列,让Observable只返回满足我们条件的数据. Debounce Debounce会过滤掉发射速率过快的数据项,相当于限流,但是需要 ...
RxJava 过滤操作符 distinct 和 distinctUntilChanged
distinct 看下文档 distinct : 过滤掉重复的元素 distinctUntilChanged: 过滤掉连续重复的元素,不连续重复的是不过滤看下代码 1 distinct Obse ...
RxJava过滤操作符 filter
filter操作符是对源observable产生的结果自定义规则进行过滤,只有满足条件的结果才会提交给订阅者: 官方流程图: .filter(new Fuc1<t1,Boolean>(){ ...
RxJava 过滤操作符 ofType
.ofType(class) 指定某个类型的class,过滤属于这个类型的的结果,其它抛弃例子: Observable.just("first", 2, 3, "fo ...
RxJava 过滤操作符 throttleFirst 与 throttleLast 以及 sample
看文档发现 throttleFirst 与 throttleLast 以及 Sample 都跳到同一个界面Sample throttleFirst :在某段时间内,只发送该段时间内第1次事件(假如一个 ...
RxJava 过滤操作符 take 与 takeLast
take 看下官方文档 take : 指定观察者正序接受指定的items数量 takeLast 指定观察者正序接受最后指定的items的数量看下demo take的代码 Observable.ju ...
RxJava 过滤操作符skip 与 skipLast
skip 看下文档 skip 是正序跳过指定的items skipLast 是正序跳过指定最后几个items 下面看下代码 Observable.just(1,2,3,4,5,6).skip(1)// ...

RxJava过滤操作符 debounce

RxJava过滤操作符 debounce相关推荐

最新文章

热门文章