RxJava中有节流阀吗？
我试图在RxJava中找到一个能够以特定方式进行节流的操作符：
- 发射元素
我似乎找不到一个符合这种行为的。我看了一些类似的，但似乎没有一个是正确的。
>
防抖/逃逸-发出元素序列中的最后一个元素，这些元素之间的间隔很短
查看设置的时间间隔并在每个时间间隔中发出最后一个元素的示例。
throttleFirst查看设置的时间间隔并在每个时间间隔中发出第一个元素。这似乎是最接近我想要的，但并不完全一样。
是否有任何RxJava操作符可以与此匹配？这似乎是一个有用的用例。
共有1个答案
我最初没有意识到，因为互联网上的大多数留档都略有关闭（http://reactivex.io/documentation/operators/sample.html，https://github.com/ReactiveX/RxJava/wiki/Filtering-Observables）。Javadocs是正确的，我在哪里找到了我要找的东西。
-
概述 φ4直通式节流阀是一种直通式流量控制阀，用于流量的调节和控制，手动旋钮控制调节，可完全锁定关闭。 尺寸图纸
-
问题内容： 我正在寻找JS中的简单节流阀。我知道像lodash和underscore这样的库都有它，但是仅对一个函数来说，包含其中任何一个库都是过大的。 我也在检查jquery是否具有类似的功能-找不到。 我发现一个工作的节流阀，这是代码： 问题是：在油门时间结束后，它将再次触发该功能。因此，假设我制作了一个在按键时每10秒触发一次的油门如果我按键2次，则在完成10秒后仍会触发第二次按键。我不要这
-
如何在骆驼的所有路线上添加油门 那可以得到不止一个Restresource_path，我怎么能在我的所有主要路线中插入油门。我知道我可以在.from（“直接：转移路由”）和.from（“直接：帐户路由”）中的每个路由的开始之后插入，但我想一般地插入我的所有资源。我可以在骆驼身上做到这一点，或者也许使用Spring更安全？
-
RxJava中是否有一个操作员、一个外部库或一种我不知道的方法来创建一个可流动/可观察的，接收控制数据排放的函数，比如阀门？ 我有一个巨大的json文件需要处理，但我必须得到文件的一部分，一个实体列表，处理它，然后得到另一部分，我尝试使用windows（），buffer（），但我传递给Flowable的双函数。generate（）在收到第一个列表但尚未完成处理后继续执行。我也试过流动变形金刚。我是
-
问题内容： 我想知道 corePoolSize 和 节流限制 之间的区别，因为Spring Batch属性定义了多线程配置。 但是我的问题涉及 corePoolSize 与 节流限制 …。我发现最好定义CorePoolSize = Throttle- limit，但是我想知道…是否定义例如：CorePoolSize = 100和Throttle-limit = 200。 。 怎么了 ？是将创建20
-
Apache Camel:2.12.2，activemq:5.7 我们注意到，在下面的路由中，对于前100次交换，节流工作正常。此后，它不是每秒发送100次交换，而是每秒仅发送1次交换。现在，如果我们将timePeriodMillis设置为100，它似乎可以正常工作。注意，我们同时发送500个交换。