RxJava异步执行单次后完成

Question

有没有一种方法可以让单个发出数据，并且当它发出数据时（或者当它完成时）以异步方式使用该数据触发完整的？

我的问题与此非常相似，但我试图异步调用Completable。

这是我试图实现的一个微不足道的例子：

Single.just("abc")
     .map(string -> {
         myHeavyCompletable(string); //this should be async
         return string;
     });

[...]

private Completable myHeavyCompletable(String string) {
    //heavy logic that could slow down the execution
}

我看到订阅映射中的Completable允许我以某种方式完成这项任务，但我不知道如何以正确的方式处理它（因为在活动中不调用此方法）。

非常感谢您的帮助，谢谢！

Answer 1

考虑在适当的线程上异步使用flatMapCompletable和subscribe。这种方法将所有逻辑组合为一个流水线序列，如果它不是您想要的，您可以在map中订阅您的completable，并返回一次性结果，最后收集它们并根据需要进行处理。