Spring boot SSE（服务器发送的事件）：如何动态发送响应

Question

我是SSE（服务器发送事件）的新手。我找到了一种在春季引导中使用SSE发送响应的方法。我能够每20秒发送一次响应。我用下面的代码相同。

public Flux<UserDto> fetchUserEvent() {
        return Flux.interval(Duration.ofSeconds(20)).map(intr -> generateUserEvent()).flatMapIterable(x -> x);
    }

generateUserEvent() - verify if new user added in DB. If it found user data, will return the same or will return empty object (new UserDto())

但是问题是，此方法每20秒调用一次。

但是，我的要求是每20秒向客户端发送一个空响应，并在新用户添加到数据库时发送响应。

我如何实现我的目标？或者我在概念上是完全错误的。