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

import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.functions.Function;
import java.util.concurrent.TimeUnit;

public class RxJavaRetryExample {

    public static void main(String[] args) {
        // 模拟两个API调用
        Observable<String> apiCall1 = callApiWithParams("param1");
        Observable<String> apiCall2 = callApiWithParams("param2");

        // 并行调用两个API
        Observable.merge(apiCall1, apiCall2)
                .retryWhen(errors -> errors
                        .zipWith(Observable.range(1, 3), (error, attempt) -> {
                            if (attempt == 3) {
                                throw new RuntimeException("Failed after 3 attempts", error);
                            }
                            return attempt;
                        })
                        .flatMap(attempt -> Observable.timer(attempt * 2, TimeUnit.SECONDS)))
                .subscribe(
                        response -> System.out.println("Response: " + response),
                        error -> System.err.println("Error: " + error.getMessage())
                );

        // 为了让程序不立即退出，等待一段时间
        try {
            Thread.sleep(20000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    private static Observable<String> callApiWithParams(String param) {
        return Observable.just(param)
                .map(p -> {
                    // 这里模拟API调用，可能会失败
                    if (Math.random() > 0.5) {
                        throw new RuntimeException("API call failed for param: " + p);
                    }
                    return "Success with param: " + p;
                });
    }
}