如何使用RxJ并行调用多个可取消请求的后端？

<dependency>
    <groupId>io.reactivex.rxjava3</groupId>
    <artifactId>rxjava</artifactId>
    <version>3.x.x</version>
</dependency>

import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.core.Observer;
import io.reactivex.rxjava3.disposables.Disposable;

public class ParallelBackendRequests {
    public static void main(String[] args) {
        // 创建多个Observable，代表不同的后端请求
        Observable<String> request1 = Observable.create(emitter -> {
            // 执行第一个后端请求的逻辑
            // ...
            emitter.onNext("Response 1");
            emitter.onComplete();
        });

        Observable<String> request2 = Observable.create(emitter -> {
            // 执行第二个后端请求的逻辑
            // ...
            emitter.onNext("Response 2");
            emitter.onComplete();
        });

        // 并行调用多个后端请求
        Observable.zip(request1, request2, (response1, response2) -> {
            // 处理多个请求的响应结果
            // ...
            return "Combined Response";
        }).subscribe(new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 可在此处进行取消操作
            }

            @Override
            public void onNext(String response) {
                // 处理响应结果
            }

            @Override
            public void onError(Throwable e) {
                // 处理错误
            }

            @Override
            public void onComplete() {
                // 请求完成
            }
        });
    }
}