RxJava中有油门吗？

Question

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

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

我似乎无法找到符合此行为的一个.我看了一些类似的,但似乎没有一个是正确的.

• debounce/ throttleWithTimeout- 发出在它们之间短时间内发出的元素序列中的最后一个元素

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

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

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

Answer 1

我正在寻找节流阀。我最初并没有意识到，因为大多数互联网上的文档稍微偏离（http://reactivex.io/documentation/operators/sample.html，https://github.com/ReactiveX/RxJava/wiki/Filtering-可观的）。Javadocs是正确的，并且在哪里找到了我想要的东西。