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