如何用Project Reactor替换Spring Events

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

import reactor.core.publisher.Flux;

public class EventPublisher {
    private Flux<String> eventStream = Flux.create(sink -> {
        // 在这里添加事件逻辑
        // 通过调用sink.next(event)来发布事件
    });

    public Flux<String> getEventStream() {
        return eventStream;
    }
}

import reactor.core.publisher.Flux;

public class EventSubscriber {
    public void processEvent(String event) {
        // 在这里处理事件
    }

    public void subscribeToEvents(Flux<String> eventStream) {
        eventStream.subscribe(this::processEvent);
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class MyComponent {
    private EventPublisher eventPublisher;
    private EventSubscriber eventSubscriber;

    @Autowired
    public MyComponent(EventPublisher eventPublisher, EventSubscriber eventSubscriber) {
        this.eventPublisher = eventPublisher;
        this.eventSubscriber = eventSubscriber;
    }

    public void doSomething() {
        // 发布事件
        eventPublisher.getEventStream().next("Event data");

        // 订阅事件
        eventSubscriber.subscribeToEvents(eventPublisher.getEventStream());
    }
}