android - 使用 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 中的以下内容:

This variant operates by default on the computation Scheduler (...)

或者，在代码方面，这当前发生了:

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

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

现在，尝试从主/ui 线程以外的任何其他线程更新 View (这就是 onNext() 中发生的事情)是错误的，它会导致不确定的结果。

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

(...) but you can optionally pass in a Scheduler of your choosing as a third parameter.

这会导致:

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

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

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

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