一、debounce语法

 public Observable<Integer> getRxJavaDebounceData() {
        return Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                LogUtils.error(TAG, "getRxJavaDebounceData--:" + Thread.currentThread().getName() + "-emitter-:" + 1);
                emitter.onNext(1);
                Thread.sleep(500);
                LogUtils.error(TAG, "getRxJavaDebounceData--:" + Thread.currentThread().getName() + "-emitter-:" + 2);
                emitter.onNext(2);
                Thread.sleep(100);
                LogUtils.error(TAG, "getRxJavaDebounceData--:" + Thread.currentThread().getName() + "-emitter-:" + 3);
                emitter.onNext(3);
                Thread.sleep(200);
                LogUtils.error(TAG, "getRxJavaDebounceData--:" + Thread.currentThread().getName() + "-emitter-:" + 4);
                emitter.onNext(4);
                Thread.sleep(10);
                LogUtils.error(TAG, "getRxJavaDebounceData--:" + Thread.currentThread().getName() + "-emitter-:" + 5);
                emitter.onNext(5);
                Thread.sleep(500);
                LogUtils.error(TAG, "getRxJavaDebounceData--:" + Thread.currentThread().getName() + "-emitter-:" + 6);
                emitter.onNext(6);
            }
        });
    }

    public void rxJavaDebounceExample() {
        model.getRxJavaDebounceData()
                .subscribeOn(Schedulers.io())
                .unsubscribeOn(Schedulers.io())
                .debounce(150, TimeUnit.MILLISECONDS)
                .observeOn(AndroidSchedulers.mainThread())
                .compose(RxLifeCycleUtils.<Integer>bindUntilEvent(view, ActivityEvent.DESTROY))
                .subscribe(new Consumer<Integer>() {
                    @Override
                    public void accept(Integer integer) throws Exception {
                        LogUtils.error(TAG, "rxJavaDebounceExample--:" + Thread.currentThread().getName() + "-consumer-:" + integer);
                    }
                });

    }

日志

08-18 16:07:55.628 29648-30017/com.example.zhang E/MainModel: getRxJavaDebounceData--:RxCachedThreadScheduler-1-emitter-:1
08-18 16:07:55.780 29648-29648/com.example.zhang E/MainPresenter: rxJavaDebounceExample--:main-consumer-:1
08-18 16:07:56.130 29648-30017/com.example.zhang E/MainModel: getRxJavaDebounceData--:RxCachedThreadScheduler-1-emitter-:2
08-18 16:07:56.231 29648-30017/com.example.zhang E/MainModel: getRxJavaDebounceData--:RxCachedThreadScheduler-1-emitter-:3
08-18 16:07:56.383 29648-29648/com.example.zhang E/MainPresenter: rxJavaDebounceExample--:main-consumer-:3
08-18 16:07:56.432 29648-30017/com.example.zhang E/MainModel: getRxJavaDebounceData--:RxCachedThreadScheduler-1-emitter-:4
08-18 16:07:56.444 29648-30017/com.example.zhang E/MainModel: getRxJavaDebounceData--:RxCachedThreadScheduler-1-emitter-:5
08-18 16:07:56.597 29648-29648/com.example.zhang E/MainPresenter: rxJavaDebounceExample--:main-consumer-:5
08-18 16:07:56.945 29648-30017/com.example.zhang E/MainModel: getRxJavaDebounceData--:RxCachedThreadScheduler-1-emitter-:6
08-18 16:07:57.097 29648-29648/com.example.zhang E/MainPresenter: rxJavaDebounceExample--:main-consumer-:6

总结

1、debounce去抖动
步骤：先发送1，发送器中保存有1
间隔500毫秒发送2，500大于150 ，所以保存1,2
间隔100毫秒发送3 ，100小于150毫秒，用3替换上一个，所以保存1,3
间隔200毫秒发送4,200大于150毫秒，所以保存1,3,4
间隔10毫秒发送5,10小于150毫秒，用5替换4，所以保存1,3,5
间隔500毫秒发送6，500大于150毫秒，所以保存1,3,5,6

河马过河微信公众号.jpg