春天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))