Spring 5 Reactor - 每 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))