RxJava -如何对两个可观察对象进行重复的takeUntil操作，一个可观察对象依赖于另一个可观察对象

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

public class RxJavaTakeUntilExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建第一个Observable，每隔一秒发出一个递增的数字
        Observable<Integer> source = Observable.interval(1, TimeUnit.SECONDS)
                .map(i -> i.intValue());

        // 创建第二个Observable，每隔三秒发出一个事件
        Observable<Object> stopSignal = Observable.interval(3, TimeUnit.SECONDS)
                .map(i -> new Object());

        // 使用flatMap和repeatWhen操作符实现重复的takeUntil操作
        source.takeUntil(stopSignal)
                .repeatWhen(completed -> completed.flatMap(i -> stopSignal.firstElement().toObservable()))
                .subscribe(
                        value -> System.out.println("Received: " + value),
                        Throwable::printStackTrace,
                        () -> System.out.println("Done")
                );

        // 等待足够的时间以便观察输出
        Thread.sleep(15000);
    }
}