弹簧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))