RxJava / RxJs:如何合并两个源观察值，但只要其中一个完成即完成

Observable<Integer> source1 = Observable.just(1, 2, 3);
Observable<Integer> source2 = Observable.just(4, 5, 6);

Observable.merge(source1, source2)
    .subscribe(new Observer<Integer>() {
        @Override
        public void onSubscribe(Disposable d) {
            // 订阅时的操作
        }

        @Override
        public void onNext(Integer value) {
            // 处理合并后的观察值
        }

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

        @Override
        public void onComplete() {
            // 处理合并完成的情况
        }
    });

import { merge } from 'rxjs';

const source1 = of(1, 2, 3);
const source2 = of(4, 5, 6);

merge(source1, source2)
    .subscribe({
        next: value => {
            // 处理合并后的观察值
        },
        error: error => {
            // 处理错误情况
        },
        complete: () => {
            // 处理合并完成的情况
        }
    });