Spring 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))

Spring 5 Reactor - Emitting item every 1 second