RxJava 有节流吗？
Is there throttle in RxJava?
我正在尝试在 RxJava 中找到一个以特定方式节流的运算符：
- 发出一个元素
- 在元素发出后的一段时间内，所有其他发出的元素都被过滤掉
我似乎找不到符合此行为的。我查看了一些类似的，但其中 none 似乎是正确的。
debounce/throttleWithTimeout - 发出一系列元素中的最后一个元素，这些元素之间的时间很短
sample/throttleLast 查看设置的时间间隔并发出每个时间间隔中的最后一个元素。
throttleFirst 查看设置的时间间隔并在每个时间间隔内发出第一个元素。这似乎是最接近我想要的，但并不完全相同。
是否有任何我可以使用的 RxJava 操作符匹配这个？这似乎是一个有用的用例。
throttleFirst was what I was looking for. I didn't realize initially because most of the documentation on the internet is slightly off (http://reactivex.io/documentation/operators/sample.html , https://github.com/ReactiveX/RxJava/wiki/Filtering-Observables)。 Javadocs 是正确的，我在哪里找到了我要找的东西。
我正在尝试在 RxJava 中找到一个以特定方式节流的运算符：
- 发出一个元素
- 在元素发出后的一段时间内，所有其他发出的元素都被过滤掉
我似乎找不到符合此行为的。我查看了一些类似的，但其中 none 似乎是正确的。
debounce/throttleWithTimeout- 发出一系列元素中的最后一个元素，这些元素之间的时间很短sample/throttleLast查看设置的时间间隔并发出每个时间间隔中的最后一个元素。throttleFirst查看设置的时间间隔并在每个时间间隔内发出第一个元素。这似乎是最接近我想要的，但并不完全相同。
是否有任何我可以使用的 RxJava 操作符匹配这个？这似乎是一个有用的用例。
throttleFirst was what I was looking for. I didn't realize initially because most of the documentation on the internet is slightly off (http://reactivex.io/documentation/operators/sample.html , https://github.com/ReactiveX/RxJava/wiki/Filtering-Observables)。 Javadocs 是正确的，我在哪里找到了我要找的东西。