如何在Java中创建异步生成器/源？

<dependency>
    <groupId>io.projectreactor</groupId>
    <artifactId>reactor-core</artifactId>
    <version>3.4.12</version>
</dependency>

import reactor.core.publisher.Flux;
import java.time.Duration;
import java.util.Random;

public class AsyncGeneratorExample {
    public static void main(String[] args) {
        // 创建一个异步生成器，每秒生成一个随机数
        Flux<Integer> asyncGenerator = Flux.interval(Duration.ofSeconds(1))
                                           .map(tick -> new Random().nextInt(100));

        // 订阅并处理生成的数据
        asyncGenerator.subscribe(
            number -> System.out.println("Received: " + number),
            error -> System.err.println("Error: " + error),
            () -> System.out.println("Completed")
        );

        // 防止主线程立即退出
        try {
            Thread.sleep(10000); // 运行10秒
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}