RxJava 中有节流阀吗？

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 是正确的，我在哪里找到了我想要的东西。