将累积的请求发送到 Web 服务 - RxJava2

Question

我在我的应用程序中有添加按钮让用户将项目添加到列表中，如果用户单击添加按钮我不请求立即转到网络服务，我希望请求每 1 秒累积并发送一次总点击次数。而不是每次用户单击添加按钮时都发送请求。

我看到为 RxSearchView 实现了类似的东西。我检查了代码太复杂了

我需要一些帮助，我应该从哪里开始解决这样的问题？或任何现成的解决方案？

Answer 1

您正在寻找debounce运营商：

返回一个镜像源 ObservableSource 的 Observable，除了它丢弃由源 ObservableSource 发出的项目，这些项目在超时值到期之前跟随更新的项目。每次发射时计时器都会重置。

只需将您的点击事件包装到Observable：

Observable<Object> getButtonObservable(final Button button) {
    return Observable.create(new ObservableOnSubscribe<Object>() {
        @Override
        public void subscribe(final ObservableEmitter<Object> e) throws Exception {
            button.setOnClickListener(new View.OnClickListener() {
                @Override
                public void onClick(View v) {
                    e.onNext(new Object()); //instead of Object you can use any data, e.g. derived from View tag
                }
            });
            e.setCancellable(new Cancellable() {
                @Override
                public void cancel() throws Exception {
                    button.setOnClickListener(null);
                }
            });
        }
    });
}

并应用该运算符不要忘记在onDestroy（onDestroyView）中取消订阅：

Button addButton;
Disposable addButtonDisposable;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    ...
    getButtonObservable(addButton)
            .doOnSubscribe(new Consumer<Disposable>() {
                @Override
                public void accept(Disposable disposable) throws Exception {
                    addButtonDisposable = disposable;
                }
            })
            .debounce(1, TimeUnit.SECONDS)
            ... //make request using flatMap or doOnNext, and subscribe
}

@Override
protected void onDestroy() {
    super.onDestroy();
    addButtonDisposable.dispose();
}