给我一个Java的响应式编程案例

响应式编程是一种编程范式，旨在解决异步数据流和事件驱动的编程问题。在 Java 中，可以使用 Reactor 等框架来实现响应式编程。

下面是一个使用 Reactor 的响应式编程的示例，它演示了如何通过 Flux 对象来发布事件，并使用 Subscriber 对象来订阅这些事件：

import reactor.core.publisher.Flux;

public class ReactiveExample {
    public static void main(String[] args) {
        Flux<Integer> numbers = Flux.range(1, 10);

        numbers.subscribe(
            System.out::println,  // onNext
            System.err::println,  // onError
            () -> System.out.println("Done")  // onComplete
        );
    }
}

上面的代码会生成一个包含数字 1 到 10 的 Flux 对象，然后使用 subscribe() 方法订阅它。在这个例子中，我们传入了三个 lambda 表达式，分别对应 onNext、onError 和 onComplete 事件的处理器。当 Flux 对象发布一个事件时，它会调用对应的处理器进行处理。在这个例子中，每当 Flux 对象发布一个数字时，它都会调用 onNext 处理器，并将数字作为参数传入。