rx-java - 速率限制 observables

Question

我有一个可观察的对象，它从数据库游标的快速流中生成数据。我希望以每秒 x 个项目的速度限制输出。到目前为止，我一直在使用文档中描述的 Callstack 阻塞:

observable.map(f -> {
ratelimiter.acquire(); // configured limiter to only allow
});

这工作正常，但出于好奇，是否有更好的方法使用背压来处理此问题？

塔克斯

Answer 1

使用 sample (throttleLast) 运算符:

Observable<T> throttled = 
    observable.sample(1 / rate, TimeUnit.MILLISECONDS);

http://reactivex.io/documentation/operators/sample.html

https://github.com/ReactiveX/RxJava/wiki/Backpressure