在rxjava中发出项后的动态间隔
在rxjava中发出项后的动态间隔
提问于 2022-01-31 10:57:53
我试图添加使用RxJava发出的列表项的动态内部。
目前，在我的流程中，每隔10秒我就会发出这些项目，但我试图实现的是，在发出第一个项目之后，会有60秒的延迟，而其余的项目将在10秒的延迟之后继续进行。
- 项目#1发出
- 60秒
- 项目#1发出
- 10秒延迟
>H 110项目2发出<代码>H 211<代码>H 11210秒延迟等等<代码>H 213/代码><代码>G 214
我的当前代码如下
.flatMap(dataList -> Observable.fromIterable(dataList)
.zipWith(Observable.interval(10, TimeUnit.SECONDS), (item, interval) -> item)
.doOnNext(data -> {
})回答 1
Stack Overflow用户
回答已采纳
发布于 2022-01-31 15:58:18
使用初始延迟为60的just()和interval()的组合
.zipWith(
Observable.just(-1L)
.concatWith(Observable.interval(60, 10, TimeUnit.SECONDS)),
(item, interval) -> item
)页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/70924811
复制相关文章
相似问题
腾讯云开发者
