android - 如何在 RxJava 中链接具有不同间隔的可观察量？

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您链接的对于单独控制每个项目的延迟非常有用。