RxJava处理单个元素错误时如何不终止整个数据流流程

需求场景：数据流执行过程中，若某个元素的处理阶段发生错误（示例中出错元素为"three"），需要保证数据流仍能继续处理其余元素。
原代码预期输出为1,2,4,5，实际仅输出1,2，原实现代码如下：

Observable<String> numbers = Observable.just("1", "2", "three", "4", "5");
numbers.map(v->{
            return  Integer.parseInt(v);
        }).onErrorResumeNext(error->{return Observable.just(-1);})
        .filter(v-> {
            System.out.println("filter value smaller than 0");
            return  v>0;
        })
        .subscribe(s -> {
            System.out.println(s);
        });

onErrorResumeNext是流级别的错误处理操作符：一旦上游流抛出异常，会直接终止原始上游序列，切换到resumeFunction返回的新流，不会再回到原始流读取后续元素。
原代码把错误处理放在整个map操作的下游，当处理"three"抛出数字格式异常时，原始的numbers序列直接终止，只会返回兜底值-1，该值被filter过滤后，流就直接结束了，自然不会处理后面的"4"和"5"。

要实现单元素出错不中断整个流，核心原则是 把错误捕获范围收敛到单个元素的处理逻辑内，不要让单个元素的异常扩散为整个流的异常，常见实现有两种：

• 方案1：在可能抛出异常的map操作内部直接捕获处理异常
  对可预期的转换异常直接在转换逻辑内捕获，返回约定的无效值，后续通过过滤逻辑丢弃无效值即可，代码示例：

Observable<String> numbers = Observable.just("1", "2", "three", "4", "5");
numbers.map(v -> {
    try {
        return Integer.parseInt(v);
    } catch (NumberFormatException e) {
        // 转换失败返回约定的无效标识
        return -1;
    }
}).filter(v -> {
    System.out.println("filter value smaller than 0");
    return v > 0;
}).subscribe(System.out::println);

• 方案2：包装单元素为独立Observable做错误隔离
  借助flatMap把每个元素转为独立的Observable，对单元素的Observable加错误兜底，单个元素处理出错只会终止当前元素对应的独立流，不会影响主序列的执行，代码示例：

Observable<String> numbers = Observable.just("1", "2", "three", "4", "5");
numbers.flatMap(v -> Observable.just(v)
        .map(str -> Integer.parseInt(str))
        // 单元素出错时返回空Observable，直接丢弃当前错误元素
        .onErrorResumeNext(error -> Observable.empty())
).filter(v -> {
    System.out.println("filter value smaller than 0");
    return v > 0;
}).subscribe(System.out::println);

两种写法运行后都可以得到预期的1,2,4,5输出，其中第二种方案通用性更强，不需要在业务转换逻辑里写冗余的try-catch，也能覆盖任意类型的处理异常。

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