RxJava异常捕获问题：IO线程异常未被doOnError捕获如何解决？

首先得纠正一个常见的认知误区：doOnError 并不是用来"捕获"或"消费"异常的——它只是一个副作用操作符，只会在异常发生时执行你指定的逻辑（比如打日志、弹Toast），但异常本身依然会沿着事件流继续向下传递。如果你的订阅（subscribe）没有提供对应的 onError 回调来处理这个异常，RxJava就会把它抛到外围代码，这就是你遇到的问题。

另外还有一个容易踩的坑：Toast必须在Android主线程执行，如果你的doOnError运行在Schedulers.IO线程里，不仅异常处理逻辑不生效，还会触发UI线程错误。

正确的实现方式 #

方案1：保留doOnError做副作用，同时在subscribe中消费异常

这种方式适合你需要在异常发生时执行Toast，同时彻底终止异常传递的场景：

Observable.fromCallable(() -> inputOutput())
    .subscribeOn(Schedulers.io()) // IO操作放在IO线程
    .observeOn(AndroidSchedulers.mainThread()) // 切换到主线程处理UI操作
    .doOnError(throwable -> {
        // 这里执行异常时的副作用：弹Toast
        Toast.makeText(getApplicationContext(), "操作失败：" + throwable.getMessage(), Toast.LENGTH_SHORT).show();
    })
    .subscribe(
        result -> {
            // 处理正常返回结果
        },
        throwable -> {
            // 这里真正"消费"异常，避免它抛到外围
            // 可以留空，也可以做额外的异常日志记录
        }
    );

方案2：用onErrorReturn吞掉异常，同时处理UI提示

如果不需要单独的副作用逻辑，也可以直接在异常处理操作符里完成Toast，并返回一个默认值让事件流正常结束：

Observable.fromCallable(() -> inputOutput())
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .onErrorReturn(throwable -> {
        Toast.makeText(getApplicationContext(), "操作失败，请重试", Toast.LENGTH_SHORT).show();
        return null; // 返回一个默认值，让事件流继续完成
    })
    .subscribe(result -> {
        // 处理结果（注意可能为null）
    });

核心错误点总结 #

1. 混淆了doOnError的作用：它只负责监听异常、执行副作用，不会终止异常传递；
2. 没有在主线程执行Toast：IO线程无法更新UI，必须通过observeOn(AndroidSchedulers.mainThread())切换线程；
3. 订阅时未提供onError回调：异常传递到订阅环节时，如果没有对应的处理逻辑，就会被RxJava抛到外围。

内容的提问来源于stack exchange，提问作者Mr.Eddart