如何链式调用两个Single.fromCallable()网络请求而非嵌套？

要实现两个依赖请求的链式调用，核心是使用RxJava的flatMap操作符——它能接收第一个Single的发射结果，返回一个新的Single，从而把两个请求串联成一条流式调用链，彻底消除嵌套回调。

修改后的实现代码 #

private void queryForUser() {
    Single.fromCallable(() -> remoteRepository.queryForUser())
            .subscribeOn(Schedulers.io()) // 仅需一次，作用于所有上游请求
            .flatMap(userResponse -> {
                // 用第一个请求的username发起第二个请求，返回新的Single
                String username = userResponse.getUsername();
                return Single.fromCallable(() -> remoteRepository.performSecondQuery(username));
            })
            .observeOn(AndroidSchedulers.mainThread()) // 最后统一切换到主线程处理结果
            .subscribe(secondQueryResult -> {
                // 处理第二个请求的成功结果
                Log.d(TAG, "performSecondQuery: " + secondQueryResult);
            }, err -> {
                // 统一处理两个请求的错误
                Log.e(TAG, "请求失败", err);
            });
}

关键说明 #

1. flatMap的作用：它是RxJava实现依赖式请求的核心操作符，能将第一个Single的输出转换为第二个Single，让整个调用流程保持链式结构，避免嵌套。
2. 线程调度优化：subscribeOn(Schedulers.io())只需调用一次，因为它会影响整个上游的所有Observable操作；observeOn(AndroidSchedulers.mainThread())放在最后，确保最终的结果回调在主线程执行。
3. 错误统一处理：链式结构下，两个请求的错误都会流入最后的onError回调，你可以在这里统一处理，也可以通过onErrorResumeNext等操作符针对不同请求的错误做差异化处理。

可选优化：拆分请求逻辑 #

如果想保持代码的模块化，可以把第二个请求封装成单独的方法，返回Single而不是直接订阅：

private Single<String> performSecondQuery(String username) {
    return Single.fromCallable(() -> remoteRepository.performSecondQuery(username));
}

然后在链式调用中直接引用：

.flatMap(userResponse -> performSecondQuery(userResponse.getUsername()))

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