Rxjava2实现防抖点击事件

为防止用户在数据加载的时候接连点击按钮造成数据混乱，我们可以用RxJava的形式实现按钮的点击事件，使用户在你规定的时间内再次点击按钮无效。

实现

1.首先引入RxJava2

implementation "io.reactivex.rxjava2:rxjava:2.1.17"
implementation 'io.reactivex.rxjava2:rxandroid:2.0.1'

2.创建一个接口，里面设置一个方法用于点击事件时触发

public interface MyClickListener {

    void onClick(View view);

}

3.封装一个proxyOnClickListener（）方法，此方法用于代替之前的点击事件方法

 public void proxyOnClickListener(int seconds, final View view, final MyClickListener myClickListener)
//seconds：表示点击按钮的时间间隔，在此间隔内点击按钮会使点击无效
//view：传进来的控件
//myClickListener：我们自己构建的接口，需实现其中的onClick（View view）方法，表示点击时触发的事件

4.创建ObserveOnSubscribe对象，此对象是Obsarveble创建时需要传入的对象

ObservableOnSubscribe<View> subscribe = new ObservableOnSubscribe<View>() {
            @Override
            public void subscribe(final ObservableEmitter<View> emitter) throws Exception {
                view.setOnClickListener(new View.OnClickListener() {//view是我们传进来的view参数
                    @Override
                    public void onClick(View v) {
                        emitter.onNext(view);//将view发送给观察者，在观察者中实现我们接口中的onClick（）方法
                    }
                });
            }
        };

5.创建观察者Observer

Observer<View> observer = new Observer<View>() {
            @Override
            public void onSubscribe(Disposable d) {

            }

            @Override
            public void onNext(View view) {
                myClickListener.onClick(view);//view是被观察者传过来的view，在这里调用接口中的方法
            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onComplete() {

            }
        };

6.观察

Observable
                .create(subscribe)//这是我们创建的ObserveOnSubscribe对象
                .throttleFirst(seconds,TimeUnit.SECONDS)//这句很关键，这是RxJava中的操作符，在规定时间内观察者不在接收被观察者发送的事件
                .subscribe(observer);

7.完整的proxyOnClickListener方法

public void proxyOnClickListener(int seconds, final View view, final MyClickListener myClickListener){

        ObservableOnSubscribe<View> subscribe = new ObservableOnSubscribe<View>() {
            @Override
            public void subscribe(final ObservableEmitter<View> emitter) throws Exception {
                view.setOnClickListener(new View.OnClickListener() {
                    @Override
                    public void onClick(View v) {
                        emitter.onNext(view);
                    }
                });
            }
        };

        Observer<View> observer = new Observer<View>() {
            @Override
            public void onSubscribe(Disposable d) {

            }

            @Override
            public void onNext(View view) {
                myClickListener.onClick(view);
            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onComplete() {

            }
        };

        Observable
                .create(subscribe)
                .throttleFirst(seconds,TimeUnit.SECONDS)
                .subscribe(observer);
    }

8.调用

proxyOnClickListener(2, button, new MyClickListener() {
            @Override
            public void onClick(View view) {
                Log.d(TAG, "onClick: ");
            }
        });

当我们点击按钮时会发现，在你第一次点击按钮的2秒内再次点击按钮，并不会打印log日志，说明我们的点击事件是无效的（其实OnClickListener中的onClick（）方法是调用了，不过在其中 emitter.onNext(view)发送的view并未被观察者接收）

源码
源码