如何在 RxJava 中以不同的间隔链接 observables？

Question

我看到很多关于让Rx 延迟事件的每次发射的帖子：How to make countdown timer with RxJS Observables?、How to use RxJava Interval Operator、Adding delay between Observable Items RxJava、RxJava delay for each item of list emitted 等。

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

基本上，我有一个 Textview 和一个字母列表，我想：

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

代码实现可能看起来像这样（但我猜doThing() 在Rx 中是无稽之谈，而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: How to get variable delay on each item emitted from a list? 的答案与字母列表一起使用，其中一个字母对两个是特殊的（可能是空？），但它似乎过于复杂。

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));

您链接的last solution 对于单独控制每个项目的延迟非常有用。