rx-java - RxJava 中有节流阀吗？

Question

我试图在 RxJava 中找到一个以特定方式进行节流的运算符：

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

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

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

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

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

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

标签： rx-javarx-java2rx-android

Answer 1

throttleFirst是我一直在寻找的。我最初没有意识到，因为互联网上的大多数文档都略有偏差（http://reactivex.io/documentation/operators/sample.html，https://github.com/ReactiveX/RxJava/wiki/Filtering-可观察的）。Javadocs 是正确的，我在哪里找到了我想要的东西。