仅在布尔可观察值中反跳假值

Question

我有一个 boolean observable（通过观察者）启动和停止 Android 服务。当 true 被传递时，服务必须立即启动。当 false 被传递时，我想对其进行去抖动，以防很快出现 true，以避免不必要的（和破坏性的）停止和启动服务。是否有可以做到这一点的标准运算符的组合，或者我必须自己编写，如果是这样，我应该基于OperatorDebounceWithTime.java 还是有更简单的方法？谢谢！

Answer 1

您似乎想要debounce(Func1) 的版本，它可以让您为每个发射的项目定义一个自定义去抖动窗口。它接受一个函数，该函数为源 Observable 发出的每个项目返回一个 Observable。如果源 Observable 在这个新生成的 Observable 终止之前发出另一个项目，则 debounce 将抑制该项目。

例如，以下代码将立即发出 true 值，并在发出之前将 false 值保持 2 秒。如果源在计时器到期之前发出另一个true 值，则false 将被抑制。

deviceTrigger
   .distinctUntilChanged()
   .debounce(startDevice -> startDevice 
               ? Observable.empty() 
               : Observable.timer(2, TimeUnit.SECONDS))
   .distinctUntilChanged();

请注意，distinctUntilChanged() 调用可能不是必需的，具体取决于您的源 Observable 是否已经不同并且您的消费者是否连续处理多个 true 值。