【发布时间】:2022-01-31 10:57:53
【问题描述】:
我正在尝试为使用RxJava 发出的列表项添加动态内部。
目前在我每 10 秒后的流程中,我正在发射项目,但我想要实现的是在发射第一个项目后会有 60 秒的延迟,然后其余项目将在 10 秒的延迟后继续。
- 项目 #1 发射
- 60 秒延迟
- 项目 #1 发射
- 10 秒延迟
- 项目 #2 发射
- 10 秒延迟等
我目前的代码如下
.flatMap(dataList -> Observable.fromIterable(dataList)
.zipWith(Observable.interval(10, TimeUnit.SECONDS), (item, interval) -> item)
.doOnNext(data -> {
})
【问题讨论】:
标签: java android rx-java rx-java2