使用Rxjs5 (Beta)限制http请求

Question

我使用的是RxJS5 (https://github.com/ReactiveX/RxJS)，我试图访问Riot，它每10分钟有500个请求，每10秒有10个请求。

我设置了一个请求对象流，我有一个订阅者准备获取它们并实际地请求它们，但是我在RxJS有点新，不确定我应该使用哪个操作员来限制请求。

Answer 1

如果您想平衡您的请求，可以使用示例:当给定的可观测性发出时，const newRequests = requestStream.sample(Observable.timer(75)); //10*60*60/500 = 72 --> 75 to be sure示例将从可观测对象发出一个元素。

Answer 2

不确定这是否是最好的方法，但我最后用一个间隔观察者压缩了请求最明显的流，所以它只在间隔滴答时才会流事件。同样，不确定这是否是最好的方法，但它有效，如下所示：

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

如果你有更好的方法，请随时回答。