弹簧5反应堆 – 每1秒发射一次物品

我试图每秒发出一次价值

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

但是它以1秒的启动延迟立刻发出一切。 我怎样才能引入每个元素发射的延迟?

Flux.just(User("A"), User("B"), User("C"))只是一个项目集合,你可能想要类似

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