java - rxjava 延迟 : How to get variable delay on each item emitted from a list?

Question

我想在从可观察列表发出的每个项目之间设置自定义延迟，作为项目本身的函数。假设我们有一个列表作为(项目，延迟):

[("item1", 2),("item2", 1),("item3", 2),("item4", 3),("item5", 2),("item6", 3)]

我希望输出是这样的:

0 seconds: 
1 seconds: 
item1
2 seconds: 
item2
3 seconds: 
4 seconds: 
item3
5 seconds: 
6 seconds: 
7 seconds: 
item4
8 seconds: 
9 seconds: 
item5
10 seconds: 
11 seconds: 
12 seconds: 
item6
Completed!
13 seconds: 

我不确定如何使用延迟/计时器运算符最好地完成此操作。通过延迟文档，但无法找到一个简单的方法。任何指针都会有所帮助。谢谢!

Answer 1

不需要任何花哨的东西。只需使用 concatMap 和 delay 运算符

jla.concatMap(s -> Observable.just(s).delay(s.delay, TimeUnit.SECONDS))           
  .subscribe(s1 -> System.out.println(s1.name + " just came..."), 
             e -> {}, 
             () -> System.out.println("Everybody came!"));