我是 RxJava 新手,我遇到了以下问题。
假设我有一系列项目,并且其中一个项目传播错误,我想忽略它并继续处理其他项目。
我有以下片段:
Observable.from(Arrays.asList("1", "2", "3"))
.map(x -> {
if (x.equals("2")) {
throw new NullPointerException();
}
return x + "-";
})
.onExceptionResumeNext(Observable.empty())
.subscribe(System.out::println);
我得到:1-
但我想得到: 1- , 3-
我怎样才能做到这一点?
诀窍是将值(将以某种方式转换)包装成新的可观察值并覆盖它的平面图,如下例所示。 flatMap 中的每个值现在都可以抛出异常并按值进行处理。由于 flatMap 中的子流仅包含一个元素,因此 onError 后是否关闭 observable 并不重要。我使用 RxJava2 作为测试环境。
@Test
public void name() throws Exception {
Observable<String> stringObservable = Observable.fromArray("1", "2", "3")
.flatMap(x -> {
return Observable.defer(() -> {
try {
if (x.equals("2")) {
throw new NullPointerException();
}
return Observable.just(x + "-");
} catch (Exception ex) {
return Observable.error(ex);
}
}).map(s -> {
if (s.equals("3-")) {
throw new IllegalArgumentException();
}
return s + s;
}).take(1)
.zipWith(Observable.just("X"), (s, s2) -> s + s2)
.onErrorResumeNext(Observable.empty());
});
TestObserver<String> test = stringObservable.test();
test.assertResult("1-1-X");
}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)