RxJava中onErrorResumeNext无法正确跳过错误值，如何获取目标结果？

RxJava: 修正错误处理以获取预期结果[1,3,5] #

你的代码存在语法错误和逻辑位置问题，导致只返回[1]，以下是修正方案：

原代码问题 #

1. 语法错误：参数未命名、p%2 == 缺少比较值、return p 未返回Observable类型（flatMap要求返回流类型）
2. 错误处理位置不对：onErrorResumeNext 未作用于每个子Observable，单个元素出错直接终止整个流

修正代码 #

Observable.fromIterable(List.of(1, 2, 3, 4, 5))
    .flatMap(p -> {
        Observable<Integer> itemStream;
        if (p % 2 == 0) {
            itemStream = Observable.error(new RuntimeException("Cannot do this"));
        } else {
            itemStream = Observable.just(p);
        }
        // 给每个子流添加错误处理：出错时转为空流，跳过该元素
        return itemStream.onErrorResumeNext(Observable.empty());
    })
    .toList()
    .subscribe(result -> System.out.println(result));

逻辑说明 #

• 给flatMap内部的每个子Observable单独设置onErrorResumeNext(Observable.empty())，这样当偶数元素触发错误时，对应的子流会被替换为空流，flatMap会忽略这个空流，继续处理后续元素
• flatMap中返回Observable.just(p)符合要求：既不是null，也没有额外包装类，直接返回元素对应的流
• 最终toList()会收集所有正常处理的元素，得到[1,3,5]

可选简化方案（RxJava 3+） #

如果你的RxJava版本是3.x及以上，官方提供了onErrorContinue操作符，可以更简洁地实现跳过错误元素的逻辑：

Observable.fromIterable(List.of(1, 2, 3, 4, 5))
    .flatMap(p -> {
        if (p % 2 == 0) {
            return Observable.error(new RuntimeException("Cannot do this"));
        }
        return Observable.just(p);
    })
    .onErrorContinue((err, item) -> {
        // 可选：在这里记录错误日志
    })
    .toList()
    .subscribe(result -> System.out.println(result));

RxJava 2.x确实没有这个操作符，所以用第一种方案即可。

内容的提问来源于stack exchange，提问作者Snopek1337