使用rx java在非定期间隔后发出事件

import io.reactivex.Observable;
import io.reactivex.disposables.Disposable;

public class RxJavaExample {
    public static void main(String[] args) {
        // 创建一个Observable对象，使用interval操作符每隔1秒发出一个递增的长整型数值
        Observable<Long> observable = Observable.interval(1, TimeUnit.SECONDS);

        // 订阅Observable对象，处理发出的事件
        Disposable disposable = observable.subscribe(
                value -> System.out.println("Received value: " + value),
                error -> System.err.println("Error: " + error),
                () -> System.out.println("Completed")
        );

        // 等待一段时间后取消订阅
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        disposable.dispose();
    }
}