rx-java - 根据值对 rx 进行去抖

Question

如果我的客户端断开连接(错误)超过 10 秒，我会尝试显示一个弹出窗口。但是，当重新连接时，我也会关闭弹出窗口(true)。如果为真，我需要立即关闭弹出窗口。

我认为我需要做的是根据值(假)进行去抖，但我不确定。

mConnectionObservable
.distinctUntilChanged()
.debounce(10, TimeUnit.SECONDS)
.subscribe(online -> {
    if (online) {
        //Dismiss popup
    } else {
        //Show popup about internet connection
    }
});

Answer 1

你可以试试

mConnectionObservable.debounce(item -> (item? Observable.empty() : Observable.timer(10,TimeUnit.SECONDS)))
                     .distinctUntilChanged()

这会动态更改去抖周期，以便始终发出真值，但发出 10 秒去抖的假值。