弹簧5反应堆-每1秒发射一次

Question

我正试图每一秒发出值

Flux.just(User("A"), User("B"), User("C")).delayElements(Duration.ofSeconds(1))

但是它是在启动延迟1秒的情况下同时发射所有的东西。我怎样才能为每个元素的发射引入延迟？

Answer 1

Flux.just(User("A"), User("B"), User("C"))只是一个项目集合，您可能需要这样的东西

Flux.fromIterable(listOf(User("A"), User("B"), User("C"))
    .delayElements(Duration.ofSeconds(1))