2017-10-04 9 views
0

私は春5原子炉 - 発光項目ごとに1秒

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

として毎秒値を放出しようとしていますが、それは1秒の遅延を開始すると、一度にすべてを放出しています。どのように各要素の放射を遅延させることができますか?

答えて

1

Flux.just(User("A"), User("B"), User("C"))は、おそらく

Flux.fromIterable(listOf(User("A"), User("B"), User("C")) 
    .delayElements(Duration.ofSeconds(1)) 
ような何かをしたいアイテムのひとつコレクションです
関連する問題