はどのようにフラックスが完全にマージから構築されたん

Question

持っている場合は、次の

Flux<String> flux1 = ... 
Flux<String> flux2 = ... 
Flux<String> mergedFlux = flux1.merge(flux2); 

方法/とき/なぜmergedFluxが完了しますか？

少なくとも驚きの原則は、結合されたフラックスのいずれかが完了したときに完了することを示唆しているかもしれません。しかし、これは私が目撃者を持っているものではありません。

Answer 1

マージの意味は、を徹底的に試して、を両方ともFluxのインターリーブされた放出を単一のFluxに再生することです。結果として、は、両方のソースが完了したときにのみ完了します。Flux

zipのような演算子とは対照的に、各ソースから1つの要素を取り出すことによってできるだけ多くのペアを生成することを目的としています。このようにして、ソースのいずれかが完了すると完了する。なぜなら、それ以降はペアをもう生成できないからである。