在使用RxJava执行周期性请求时如何避免重复请求
在使用RxJava执行周期性请求时如何避免重复请求
提问于 2018-08-02 11:57:01
我想使用RxJava (实际上是RxJava2)定期发送网络(RxJava2 )请求。第一次尝试看起来或多或少是这样的(从这个来源改编)：
Observable.interval(5, TimeUnit.SECONDS, Schedulers.io())
.map(tick -> sendNetworkRequest())这将每5秒调用一次sendNetworkRequest。
但是，如果sendNetworkRequest()需要一段时间才能完成(例如，在一个缓慢的网络上，或者如果有多个重试)这些请求将重叠。
我要做的是确保请求之间有5秒的间隔，即从上一个请求结束到下一个请求的开始。
如何用RxJava实现这一点？
回答 1
Stack Overflow用户
回答已采纳
发布于 2018-08-02 15:48:24
使用repeatWhen
Observable.fromCallable(sendNetworkRequest())
.repeatWhen(observable -> observable.delay(5, TimeUnit.SECONDS));页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/51653054
复制相关文章
相似问题
腾讯云开发者
