Merge multiple sources.

Fan-in operators



Merge multiple sources. Prefer one source if all sources have elements ready.

Reactive Streams semantics

emits when one of the inputs has an element available, preferring a defined input if multiple have elements available

backpressures when downstream backpressures

completes when all upstreams complete (This behavior is changeable to completing when any upstream completes by setting eagerComplete=true.)

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.