RxJava Zip操作符中Observable错误未向上冒泡的问题排查

哥们，你踩了一个RxJava里很容易忽略的新手坑——你在getOneThing()和getAnotherThing()里直接throw Exception()，这个异常根本没进入Rx的错误处理管道，而是在Single对象创建之前就同步抛出了，自然会导致系统崩溃，哪怕加onErrorReturn也没用，因为Rx还没来得及接管这个流程。

先拆解不同异常的处理逻辑： #

• BiFunction里的异常：这是在Rx序列执行过程中（zip操作符合并两个Single的结果时）抛出的，属于Rx管道内的异常，所以会被下游的subscribeBy的onError正常捕获。
• getOneThing/getAnotherThing里的异常：你看这两个函数的逻辑，是先判断条件直接throw，然后才返回Single.just(...)——也就是说，当isOneBadCondition为true时，函数在返回Single对象之前就同步抛出了异常，这个异常根本没被Rx的上下文包裹，Rx的错误操作符（比如onErrorReturn）完全没机会拦截它。

正确的写法应该是怎样的？ #

你需要把异常包装成Rx的错误事件发射，而不是直接同步抛出。有两种常用方式：

方式1：用Single.error()替代直接throw

修改你的两个Single生成函数，把同步throw改成返回Single.error()：

private fun getOneThing(): Single<String> {
    println("getOneThing")
    return if (isOneBadCondition) {
        Single.error(Exception("Bad condition for OneThing")) // 用Rx的错误事件发射异常
    } else {
        Single.just("a string thing")
    }
}

private fun getAnotherThing(): Single<Boolean> {
    println("getAnotherThing")
    return if (isAnotherBadCondition) {
        Single.error(Exception("Bad condition for AnotherThing"))
    } else {
        Single.just(true)
    }
}

这样修改后，异常就进入了Rx的管道，你现在再给这两个Single加onErrorReturn就能正常生效了：

Single.zip(
    getOneThing().onErrorReturn { "fallback string" },
    getAnotherThing().onErrorReturn { false },
    BiFunction<String, Boolean, Int> { t1, t2 -> createSomethingElse() }
).subscribeBy(
    onSuccess ={ println(it) },
    onError={ it.printStackTrace() }
)

方式2：用Single.defer()包裹可能抛异常的逻辑

如果你的逻辑里确实有同步代码可能抛异常（比如一些复杂的初始化），可以用Single.defer()延迟执行这段逻辑，确保异常被Rx捕获：

private fun getOneThing(): Single<String> {
    return Single.defer {
        println("getOneThing")
        if (isOneBadCondition) {
            throw Exception() // 现在这个异常会被defer捕获，转换成Rx错误事件
        } else {
            Single.just("a string thing")
        }
    }
}

defer的作用是延迟创建Single对象，直到订阅发生，并且会把同步抛出的异常自动转换成Rx的错误事件，这样后续的onErrorReturn就能正常处理了。

关键总结 #

记住RxJava的错误处理机制只对序列执行阶段的异常生效——也就是那些在Observable/Single发射事件过程中抛出的异常。如果是在创建Observable/Single对象之前同步抛出的异常，Rx根本管不到，只能靠普通的try-catch或者转换成Rx的错误事件来处理。

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