【问题标题】:Spring 5 Reactor - Emitting item every 1 secondSpring 5 Reactor - 每 1 秒发射一次
【发布时间】:2017-10-04 10:30:03
【问题描述】:

我试图每秒发出价值

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

但它会以 1 秒的启动延迟立即发射所有内容。如何为每个发射元素引入延迟?

【问题讨论】:

    标签: spring kotlin rx-java reactor


    【解决方案1】:

    Flux.just(User("A"), User("B"), User("C")) 只是项目的一个集合,您可能想要类似的东西

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2013-04-25
      • 1970-01-01
      • 2015-03-27
      • 2016-03-21
      • 2012-10-26
      • 1970-01-01
      相关资源
      最近更新 更多