android - RxAndroid : Possible to use zip function on an array of api requests with interval or delay?

Question

我正在玩 RxAndroid。我有一个 Observables 列表，所有这些都是 api 请求(使用 Retrofit)。我想每隔 x 秒或毫秒触发其中​​一个，然后将响应压缩在一起。我似乎一旦订阅了 Observable.zip(requests, someFunction) 所有这些都会立即被解雇。有什么建议吗？

谢谢!

编辑:看起来像为每个请求添加 delaySubscription 可能是答案

Answer 1

您正在寻找 delay() 或 delaySubscription() .

delay()将延迟向订阅者发布 Observable 的结果。 delaySubscription()将延迟对 Observable 的订阅。


Observable.zip(someObservable.delaySubscription(100, TimeUnit.MILLISECONDS),
someOtherObservable.delaySubscription(200, TimeUnit.MILLISECONDS),
someThirdObservable.delaySubscription(300, TimeUnit.MILLISECONDS),
new Func3<Object, Object, Object, Void>() {
...
}).subscribe();