<dependencies>
    <!-- Reactor Core（响应式编程核心库） -->
    <dependency>
        <groupId>io.projectreactor</groupId>
        <artifactId>reactor-core</artifactId>
        <version>3.6.5</version>
    </dependency>
</dependencies>

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public class ReactiveDemo {
    public static void main(String[] args) {
        // 1. 创建一个包含 1, 2, 3 的 Flux 数据流
        Flux<Integer> numbers = Flux.just(1, 2, 3)
                .log(); // 打印日志（观察数据流事件）

        // 2. 使用操作符处理数据流
        Flux<String> processedStream = numbers
                .filter(n -> n % 2 == 0)          // 过滤偶数
                .map(n -> "Number: " + n)         // 转换为字符串
                .doOnNext(s -> System.out.println("Processed: " + s)); // 副作用操作

        // 3. 订阅并消费数据流
        processedStream.subscribe(
                item -> System.out.println("Received: " + item), // 处理数据
                error -> System.err.println("Error: " + error),  // 错误处理
                () -> System.out.println("Stream completed")     // 完成回调
        );

        // 保持主线程不退出（仅示例需要）
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}