为防止用户在数据加载的时候接连点击按钮造成数据混乱，我们可以用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并未被观察者接收）
源码
源码
