与RxJava并行调用独立的网络调用并处理错误

implementation 'io.reactivex.rxjava3:rxjava:3.x.y'

Observable<Result> networkCall1 = Observable.fromCallable(() -> {
    // 执行第一个网络调用
    return performNetworkCall1();
});

Observable<Result> networkCall2 = Observable.fromCallable(() -> {
    // 执行第二个网络调用
    return performNetworkCall2();
});

Observable<Result> networkCall3 = Observable.fromCallable(() -> {
    // 执行第三个网络调用
    return performNetworkCall3();
});

Observable.zip(networkCall1, networkCall2, networkCall3, (result1, result2, result3) -> {
    // 合并结果
    return mergeResults(result1, result2, result3);
})
.subscribeOn(Schedulers.io()) // 在IO线程执行网络请求
.observeOn(AndroidSchedulers.mainThread()) // 在主线程处理结果
.subscribe(
    result -> {
        // 处理成功结果
        handleSuccess(result);
    },
    error -> {
        // 处理错误
        handleError(error);
    }
);