Spring 5 réacteur - Emitting point chaque 1 seconde

Question

Je suis en train d'émettre la valeur chaque seconde

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

mais il émet tout à la fois avec un retard à partir de 1 seconde. Comment puis-je introduire le délai pour chaque élément émettant?

Answer 1

Flux.just(User("A"), User("B"), User("C")) est juste une collection d'objets, vous voulez probablement quelque chose comme

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