RxRoom中Single触发onError时如何映射至另一个Single？

嘿，这个场景我太熟悉了！RxRoom的Single在查询不到结果时确实会直接抛出EmptyResultSetException触发onError，刚好可以用RxJava的操作符优雅地切换到远程请求，这里有两种实用的实现方式：

方法一：用onErrorResumeNext直接捕获异常（无需修改Dao） #

如果不想改动已定义好的UserDao，可以直接在订阅链里用onErrorResumeNext操作符，当原Single抛出空结果异常时，自动切换到远程请求的Single：

userDao.getUser()
    .onErrorResumeNext(throwable -> {
        // 精准捕获Room的空结果异常，避免误处理其他错误（比如数据库异常）
        if (throwable instanceof EmptyResultSetException) {
            return getRemoteUser();
        }
        // 其他异常继续抛出，交给下游处理
        return Single.error(throwable);
    })
    .subscribe(
        userEntity -> {
            // 处理获取到的用户数据（本地或远程）
        },
        error -> {
            // 处理真正的错误（比如网络请求失败、数据库连接问题）
        }
    );

这种方式的好处是不需要修改现有Dao层代码，直接在业务层处理异常即可，适合快速适配已有代码的场景。

方法二：改用Maybe类型（更符合Rx语义，推荐） #

RxJava的Maybe类型本身就代表“可能有数据，也可能没有”，刚好匹配“本地可能无用户”的场景。我们可以先修改UserDao的返回类型：

@Dao 
public interface UserDao {
    @Query("SELECT * FROM user LIMIT 1")
    Maybe<UserEntity> getUser();
}

然后用switchIfEmpty操作符，当Maybe触发onComplete（即无数据）时，自动切换到远程请求：

userDao.getUser()
    .switchIfEmpty(getRemoteUser())
    .subscribe(
        userEntity -> {
            // 处理获取到的用户数据
        },
        error -> {
            // 处理错误（比如网络请求失败）
        },
        () -> {
            // 注意：如果远程请求也没有返回数据，会走到这里
            // 可以在这里处理“本地和远程都无用户”的场景
        }
    );

这种方式更符合RxJava的设计理念，代码更简洁，也不需要判断异常类型，是我更推荐的方案——毕竟用合适的类型表达合适的语义，能减少很多不必要的异常处理逻辑。

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