使用 Rxjs5 (Beta) 限制 http 请求

Question

我正在使用 RxJS5 (https://github.com/ReactiveX/RxJS)，我正在尝试访问 Riot API，它的上限为每 10 分钟 500 个请求和每 10 秒 10 个请求。

我设置了一个请求对象流，我有一个订阅者准备好获取它们并实际请求它们，但我对 RxJS 有点陌生，不确定我应该使用哪个运算符来限制请求。

Answer 1

不确定这是否是最好的方法，但我最终使用间隔观察器压缩了请求对象流，因此它只会在间隔滴答时流式传输事件。再次，不确定这是否是最好的方法，但它有效，这是它的样子：

raw_stream = Rx.Observable.fromEvent EventEmitter, 'event'
interval = Rx.Observable.interval(1000)
timed_events = Rx.Observable.zip interval, raw_stream

如果大家有更好的方法欢迎大家解答

Answer 2

如果你想平衡你的请求，你可以使用示例： const newRequests = requestStream.sample(Observable.timer(75)); //10*60*60/500 = 72 --> 75 to be sure 当给定的 observable 发出

时，Sample 将从 observable 发出一个元素

使用 Rxjs5 (Beta) 限制 http 请求

Using Rxjs5 (Beta) to cap http requests

rxjs

rxjs5