剑客
关注科技互联网

RxJava操作符实践:3_过滤操作之10_debounce

仅在过了一段指定的时间还没发射数据时才发射一个数据。

Debounce操作符会过滤掉发射速率过快的数据项。

RxJava将这个操作符实现为throttleWithTimeout和debounce。

注意:这个操作符会会接着最后一项数据发射原始Observable的onCompleted通知,即使这个通知发生在你指定的时间窗口内(从最后一项数据的发射算起)。也就是说,onCompleted通知不会触发限流。

二、示意图

RxJava操作符实践:3_过滤操作之10_debounce

三、示例代码

Observable.create(new Observable.OnSubscribe<Integer>() {
@Override
public void call(Subscriber<? super Integer> subscriber) {
if(subscriber.isUnsubscribed()) return;
try {
//产生结果的间隔时间分别为100、200、300...900毫秒
for (int i = 1; i < 10; i++) {
subscriber.onNext(i);
Thread.sleep(i * 100);
}
subscriber.onCompleted();
}catch(Exception e){
subscriber.onError(e);
}
}
})
.subscribeOn(Schedulers.newThread())
.debounce(400, TimeUnit.MILLISECONDS) //超时时间为400毫秒
.subscribe(new Subscriber<Integer>() {
@Override
public void onCompleted() {
System.out.println("onCompleted.");
}

@Override
public void onError(Throwable e) {
System.out.println("onError:" + e.getMessage());
}

@Override
public void onNext(Integer integer) {
System.out.println("onNext:" + integer);
}
});

由于1-4这四个数值,间隔时间(分别为100ms,200ms,300ms,400ms)均不大于debounce限制的值(400ms),所以均被过滤掉,只有后面发射的时间间隔大于400ms的(分别为500ms-900ms),才会正常发射。

四、运行结果

onNext: 5
onNext: 6
onNext: 7
onNext: 8
onNext: 9
onCompleted.

项目代码已上传到Github: https://github.com/SherlockShi/RxJavaBestPractise

五、更多

跟debounce相关的操作符还有:

  • throttleWithTimeout(long,TimeUnit) 和 debounce(long,TimeUnit)
  • throttleWithTimeout(long,TimeUnit,Scheduler) 和 debounce(long,TimeUnit,Scheduler)

详情可查阅下面的参考资料。

分享到:更多 ()

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址