Rxjava -如何在并行调用两个API时使用不同的参数重试API调用

Observable<String> api1 = Observable.just("param1")
        .flatMap(param -> {
            // 调用API1，并在失败时进行重试
            return callApi1(param)
                    .retryWhen(errors -> errors
                            .zipWith(Observable.range(1, 3), (throwable, retryCount) -> {
                                if (retryCount < 3) {
                                    // 设置重试间隔为1秒
                                    return Observable.timer(1, TimeUnit.SECONDS);
                                } else {
                                    // 不再重试，抛出错误
                                    return Observable.error(throwable);
                                }
                            })
                    );
        });

Observable<String> api2 = Observable.just("param2")
        .flatMap(param -> {
            // 调用API2，并在失败时进行重试
            return callApi2(param)
                    .retryWhen(errors -> errors
                            .zipWith(Observable.range(1, 5), (throwable, retryCount) -> {
                                if (retryCount < 5) {
                                    // 设置重试间隔为2秒
                                    return Observable.timer(2, TimeUnit.SECONDS);
                                } else {
                                    // 不再重试，抛出错误
                                    return Observable.error(throwable);
                                }
                            })
                    );
        });

Observable.zip(api1, api2, (result1, result2) -> {
    // 处理API1和API2的结果
    return result1 + " " + result2;
})
.subscribe(result -> {
    // 处理最终结果
    System.out.println("Final result: " + result);
}, error -> {
    // 处理错误
    System.err.println("Error: " + error.getMessage());
});