Feder 5 Reactor - Ausstrahlen Artikel alle 1 Sekunde

Question

Ich versuche, alles zu emittieren Wert jede Sekunde als

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

aber es aussendet sofort mit einer Verzögerung von 1 Sekunde zu starten. Wie kann ich die Verzögerung für jedes emittierende Element einführen?

Answer 1

Flux.just(User("A"), User("B"), User("C")) ist nur eine Sammlung von Gegenständen, werden Sie wahrscheinlich wollen etwas wie

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