一、描述

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

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

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

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

二、示意图

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)

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

六、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS：欢迎关注 SherlockShi 个人博客