使用 Rxjava zip 运算符时跟踪特定的 zipped Observable 错误

Question

如果我使用 Rxjava zip 运算符，假设它压缩了 4 个不同的网络调用。 例如：

Observable.zip(networkCall1, networkCall2, networkCall3, networkCall4),
(model1, model2, model3, model4) ->
Mapper.getResult(model1, model2, model3, model4)).subscribe(result -> {
//do some work
});

现在如果错误处理依赖于知道哪个 Observable 导致了这个错误，我怎么知道是哪个 Observable 引发了错误。有没有任何 Rx 方法可以在不中断流的情况下知道这样的事情。

Answer 1

要知道是哪个 observable 导致了错误，您需要注释每个 observable。

Observable.zip(
 networkCall1
   .onErrorResumeNext( error -> Observable.error( new IllegalStateException( "stream1", error) ) ),
 networkCall2
   .onErrorResumeNext( error -> Observable.error( new IllegalStateException( "stream2", error) ) ),
 networkCall3
   .onErrorResumeNext( error -> Observable.error( new IllegalStateException( "stream3", error ) ) ),
 networkCall4
   .onErrorResumeNext( error -> Observable.error( new IllegalStateException( "stream4", error ) ) ) ),
(model1, model2, model3, model4) ->
Mapper.getResult(model1, model2, model3, model4)).subscribe(result -> {
//do some work
});

然后，在您的错误处理程序中，处理 IllegalStateException，解开流名称和原始错误。