关于Reactor 3示例中myEventProcessor.register及自定义类的疑问

• MyEventProcessor是指南示例中的虚构类，需要你自行定义。这个类用来代表业务中实际存在的外部异步事件源/处理器，指南用它演示Flux.create()如何对接自定义的异步事件流。
• myEventProcessor.register语句的作用是：向你的事件处理器注册一个回调逻辑。当外部事件源产生新事件时，这个回调会被触发，进而通过Reactor的Sink将事件发射到响应式流中。

你可以根据自己的业务场景实现这个类，比如对接消息队列、定时任务、第三方异步API等。以下是一个简单的参考实现：

import java.util.ArrayList;
import java.util.List;
import java.util.function.Consumer;

// 自定义事件类型，根据业务需求设计字段
class MyEvent {
    private String content;

    public MyEvent(String content) {
        this.content = content;
    }

    public String getContent() {
        return content;
    }
}

// 自定义事件处理器
class MyEventProcessor {
    private final List<Consumer<MyEvent>> eventHandlers = new ArrayList<>();

    // 注册事件回调，对应示例中的register调用
    public void register(Consumer<MyEvent> eventHandler) {
        eventHandlers.add(eventHandler);
    }

    // 模拟外部事件触发逻辑（实际场景中可能是消息监听、定时任务触发等）
    public void simulateEvent(String eventContent) {
        MyEvent event = new MyEvent(eventContent);
        // 触发所有已注册的回调
        eventHandlers.forEach(handler -> handler.accept(event));
    }
}

在这个实现中，当调用myEventProcessor.simulateEvent()时，注册的回调就会收到事件，并可以通过Sink.next()将事件推入Reactor流中，和指南示例的逻辑对应。

内容的提问来源于stack exchange，提问作者Kiyose