使用 Rx 去抖动按钮点击

Question

我正在尝试制作一个简单的“按钮去抖动器”，它将计算过滤的点击次数并通过 TextView 显示它。我想过滤快速/垃圾邮件点击，以忽略中间间隔小于 300 毫秒的点击。

我进行了研究，偶然发现了 Rx 很棒的 debounce()，理论上它应该可以做我想做的事情..

..或者我是这么想的。由于该应用程序似乎只注册了第一次点击；无论我尝试等待多长时间，计数器都不会增加。

这是我的一段代码：

    ...

    RxView.clicks(mButton)
        .debounce(300, TimeUnit.MILLISECONDS)
        .subscribe(new Subscriber<Object>() {
            public int mCount;

            @Override
            public void onCompleted() {
            }

            @Override
            public void onError(Throwable e) {
            }

            @Override
            public void onNext(Object o) {
                mText.setText(String.valueOf(++mCount));
            }
        });

    ...

我做错了什么？我尝试在没有debounce() 的情况下运行该东西，并且它运行良好（每次单击按钮时计数器都会增加）。

提前致谢！

Answer 1

注意documentation on the debounce operator中的以下内容：

默认情况下，此变体在计算调度程序（...）上运行

或者，就代码而言，目前正在发生这种情况：

public final Observable<T> debounce(long timeout, TimeUnit unit) {
    return debounce(timeout, unit, Schedulers.computation());
}

因此，订阅者的回调在同一个计算调度程序上被调用，因为没有明确的指示。

现在，尝试从除 main/ui 线程之外的任何其他线程更新视图（onNext() 中正在发生的事情）是错误的，它会导致不确定的结果。

幸运的是，上面引用的其余部分也提供了解决方案：

(...) 但您可以选择传入您选择的调度程序作为第三个参数。

这会导致：

RxView.clicks(mButton)
    .debounce(300, TimeUnit.MILLISECONDS, AndroidSchedulers.mainThread())
    .subscribe(...);

或者，您仍然可以让计算调度程序上发生去抖动，但在主/ui线程上接收通知：

RxView.clicks(mButton)
    .debounce(300, TimeUnit.MILLISECONDS)
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(...);

无论哪种方式都将确保在主/ui线程上接收通知，从而从正确的线程更新视图。