如果 RxJava 失败，如何恢复映射列表

Question

给定以下代码，onErrorResumeNext 方法只会用“hi”替换列表中的错误项。我将如何让它继续迭代列表的其余部分？

List<Object> list = new ArrayList<>();
list.add("one");
list.add(new Testo());
list.add("two");
list.add("three");    

Observable.fromIterable(list)
    .map(item -> item.toString())
    .onErrorResumeNext(Observable.just("hi"))
    .subscribe(item -> System.out.println(item), onError -> System.out.println("error"));

private static class Testo {
    @Override
    public String toString() {
        throw new NullPointerException();
    }
}

Answer 1

您可以添加一个内部反应流，因此在发生错误时外部不会终止：

Observable.fromIterable(list)
    .flatMap((item) -> Observable.just(item)
        .map(_item -> _item.toString())
        .onErrorResumeNext(Observable.just("hi")))
    .subscribe(item -> System.out.println(item), onError -> System.out.println("error"));