在RxJava中，如何以不同的间隔链接可观察对象？

Question

我看到了很多关于让Rx延迟事件的每次发射的帖子：如何让RxJS可以观测到倒计时？，如何使用RxJava间隔运算符，在可观察项RxJava之间添加延迟，为发出的列表的每个项添加RxJava延迟，以及其他。

不过，我没有看到任何不同延迟的链接。

基本上，我有一个文本视图和一个字母列表，我想：

• 将文本设置为第一个字母
• 等待1500ms
• 将文本设置为null
• 等待500ms
• 将文本设置为第二个字母
• 等待1500ms
• 将文本设置为null
• 等待500ms
• 重复整个列表

代码实现可能看起来像这样（但我想在Rx中，doThing（）是毫无意义的，而delay（）不是这个意思）：

Observable.fromArray(new String[]{"A", "B", "C", "D", "E"})
        .subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.mainThread())
        .delay(500L, TimeUnit.MILLISECONDS)
        .doThing((String i) -> {
            textView.setText("");
            Log.d("XXX", "MainActivity :: onCreate (110): letter="+ i);
        })
        .delay(1500L, TimeUnit.MILLISECONDS)
        .doThing((String i) -> {
            textView.setText(i);
            Log.d("XXX", "MainActivity :: onCreate (110): letter="+ i);
        });

如何使用Rx实现这一点？

编辑：我可以使用rxjava delay的答案：如何获得列表中每个项目的可变延迟？有一个字母列表，其中两个字母上的一个字母是特殊的（可能是空的？），但它似乎过于复杂了。

Answer 1

序列：A（1500ms）null（500ms）B（1500ms）null（500ms）C（500ms）null（1500ms）

textAnimationDisposable = Observable.fromArray("A", "B", "C")
        .concatMap(string ->
              Observable.merge(
                 Observable.just(string),
                 Observable.just("").delay(1500, TimeUnit.MILLISECONDS)
              )
              .concatWith(Observable.<String>empty().delay(500, TimeUnit.MILLISECONDS))
        )
        .observeOn(AndroidSchedulers.mainThread())
        .subscribeOn(Schedulers.newThread())
        .subscribe(string -> textView.setText(string));

您链接的最后一个解决方案对于单独控制每个项目的延迟非常有用。