java - RxJava Observable 出错时继续并获取状态

Question

在 RxJava(或一般的 RX)中，是否有任何方法可以组合可观察量，使生成的可观察量等待，直到每个可观察量以任一方式完成(当其中任何一个抛出错误时都不会 panic )，然后完成单个结果包含有关哪个可观察对象成功完成以及哪个遇到错误的信息？

如果成功完成，它还会返回 observable 的结果，或者如果完成失败，它还会返回错误原因(例如 Throwable 实例)？

行为与此类似(RSVP.js):

https://github.com/tildeio/rsvp.js/#all-settled-and-hash-settled

我可以选择实现一个类似于 Scala 的 Try 的概念，将此类可观察量发出的值包装到 Try 值中并使用 http://reactivex.io/documentation/operators/catch.html处理错误并将它们转换为错误值...但这将是手动工作，因此我想知道是否有一些预制的运算符，我在阅读文档时错过了或没有正确理解

编辑:它不需要是单个结果，我会选择 observable，它也会发出包含在 Try 构造中的所有值:)

Answer 1

.materialize()可能就是您正在寻找的。它转换Observable<T>进入Observable<Notification<T>>其中 Notification是一个值、错误或完成。