【发布时间】:2017-10-04 10:30:03
【问题描述】:
我试图每秒发出价值
Flux.just(User("A"), User("B"), User("C")).delayElements(Duration.ofSeconds(1))
但它会以 1 秒的启动延迟立即发射所有内容。如何为每个发射元素引入延迟?
【问题讨论】:
标签: spring kotlin rx-java reactor
我试图每秒发出价值
Flux.just(User("A"), User("B"), User("C")).delayElements(Duration.ofSeconds(1))
但它会以 1 秒的启动延迟立即发射所有内容。如何为每个发射元素引入延迟?
【问题讨论】:
标签: spring kotlin rx-java reactor
Flux.just(User("A"), User("B"), User("C")) 只是项目的一个集合,您可能想要类似的东西
Flux.fromIterable(listOf(User("A"), User("B"), User("C"))
.delayElements(Duration.ofSeconds(1))
【讨论】: