关于选择可观察对象的 Rxjava 新手问题

Rxjava newbee question around chosing an observable

遇到一个我似乎无法找到好的解决方案的问题。我有 2 个正在尝试观察的可观察对象。在会话期间,只有 1 个会吐出信息,而另一个会在我观察时抛出异常。他们return的数据是一样的。 有没有一种简单的方法可以让我同时观察两个可观察对象而不必包装异常?

observeA = Observable A
observeB = Observable B

Observable.<>(observeA, observeB).subscribeOn(blah)

谢谢!

如果您根本不关心异常,您可以使用 merge 观察两者并 onErrorComplete 每个忽略错误:

observeA = Observable A
observeB = Observable B

Observable.merge(
    observeA.onErrorComplete(), 
    observeB.onErrorComplete()
).subscribeOn(blah)