java - RxJava反弹

我正在尝试在1000ms的窗口内对100ms的生产者进行反抖动。
我希望看到订阅每1秒更新一次，并使用该时间段内发出的最后一个值，但是我什么也没收到。
我在这里想念什么？

public static void main(String[] args) throws InterruptedException {
    Observable
      .interval(100, TimeUnit.MILLISECONDS)
      .debounce(1000, TimeUnit.MILLISECONDS)
      .subscribe(
          update -> System.out.println(new Date().toString() + " " + update),
          error -> System.out.println("ERROR")
      );
    Thread.sleep(20000);
  }

最佳答案

找到了。我试图在RXJava中找到一个与RxJS的debounceTime（）等效的运算符，它恰好是sample（）或油门Last（）。

关于java - RxJava反弹，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/46476133/