RxJava功能防抖

依赖

//Rxjava
    implementation 'io.reactivex.rxjava2:rxjava:2.0.2'
    implementation 'io.reactivex.rxjava2:rxandroid:2.0.2'
    implementation 'com.jakewharton.rxbinding2:rxbinding:2.0.0'

Button bt = findViewById(R.id.bt);

           RxView.clicks(bt)
                      // 两秒之内点击多次只响应一次点击事件
                        .throttleFirst(2, TimeUnit.SECONDS)
                        .subscribe(new Observer<Object>() {
                            @Override
                            public void onSubscribe(Disposable d) {

                            }

                            @Override
                            public void onNext(Object value) {
                                Log.d(TAG, "发送了网络请求");
                            }

                            @Override
                            public void onError(Throwable e) {
                                Log.d(TAG, "对Error事件作出响应" + e.toString());
                                // 获取异常错误信息
                            }

                            @Override
                            public void onComplete() {
                                Log.d(TAG, "对Complete事件作出响应");
                            }
                        });