在 rxjava 中发射项目后的动态间隔

Question

我正在尝试为使用 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 -> {
                
            })

Answer 1

使用 just() 和 interval() 的组合，初始延迟为 60

.zipWith(
        Observable.just(-1L)
        .concatWith(Observable.interval(60, 10, TimeUnit.SECONDS)), 
        (item, interval) -> item
)

在 rxjava 中发射项目后的动态间隔

dynamic interval after emitting item in rxjava

java

android

rx-java

rx-java2