RxKotlin 中的区块链并继续答案

【问题标题】：Block Chain in RxKotlin and ProceedRxKotlin 中的区块链并继续
【发布时间】：2019-05-14 12:39:54
【问题描述】：

我的应用程序中有一个链接操作，其中我有一些数据的列表，一旦迭代完成，我将使用 iteratable observable 遍历列表，我将执行一些不依赖于前一个列表的其他操作，所以我需要的是在这两个操作之间我需要阻塞（或屏障）直到第一个完成并继续第二个。

例子

Observable.fromIterable(listOf("A","B","C","D"))
          .map{
            doSomeTask(it)
          } 
   // I need a blocking here, once this iteration completes i will proceed with the below task, but i don't need of toList() to block since i don't want the data,       
          .map{
            doSomeOtherTask()
          }

谁能帮我解决这个问题？

【问题讨论】：

标签： android kotlin rx-java2 rx-kotlin2

【解决方案1】：

如果您想传播每个值，请使用doOnNext，如果您想在迭代结束时执行某项操作，请使用doOnComplete。

【讨论】：

【解决方案2】：

你可以做的如下：

Observable.fromIterable(listOf("A", "B", "C", "D"))
        .subscribeBy(
            onNext = {
                doSomeTask(it)
            },
            onComplete = {
                doSomeOtherTask()
            }
        )

这样您就可以达到预期的效果。干杯！

【讨论】：