rx-java - RxJava有 throttle 吗？

Question

我正在尝试在 RxJava 中找到一个能够以特定方式进行限制的运算符:

• 发出一个元素
• 在元素发出后的一段时间内，所有其他发出的元素都会被过滤掉

我似乎找不到与这种行为相匹配的。我看了一些类似的，但似乎没有一个是正确的。

• debounce/throttleWithTimeout - 发出一系列元素中的最后一个元素，这些元素之间的间隔很短

• sample/throttleLast 查看设置的时间间隔并发出每个时间间隔中的最后一个元素。

• throttleFirst 它查看设置的时间间隔并在每个时间间隔中发出第一个元素。这似乎是最接近我想要的，但并不完全相同。

有没有我可以使用的与此匹配的 RxJava 运算符？这似乎是一个有用的用例。

Answer 1

throttleFirst这就是我一直在寻找的。我最初没有意识到，因为互联网上的大多数文档都略有偏差( http://reactivex.io/documentation/operators/sample.html ， https://github.com/ReactiveX/RxJava/wiki/Filtering-Observables )。 Javadocs 是正确的，并且我在其中找到了我正在寻找的内容。