spring - spring webflux中sse区间的解决方法

Question

我使用 Spring webflux 构建，服务器发送事件一个端点，当 MongoDB 更改时需要通知我的前端。

但要实现这一点，我必须使用 Flux.interval 并逐秒阅读我的 MongoDb。

有没有更好的方法在 MongoDb 更改时通知我的前端？

我的代码

public Flux<CheckResponse> checkMongo(String id) throws InterruptedException {
    return Flux.interval(Duration.ofSeconds(1)).map(sequence -> {
        return gateway.checkMongo(id);
    });
}