reactor-core/src/main/java/reactor/core/publisher/Flux.java
@SafeVarargs
	public static <T> Flux<T> mergeOrdered(Comparator<? super T> comparator, Publisher<? extends T>... sources) {
		return mergeOrdered(Queues.SMALL_BUFFER_SIZE, comparator, sources);
	}
@SafeVarargs
	public static <T> Flux<T> mergeOrdered(Comparator<? super T> comparator, Publisher<? extends T>... sources) {
		return mergeOrdered(Queues.SMALL_BUFFER_SIZE, comparator, sources);
	}
Merge data from provided {@link Publisher} sequences into an ordered merged sequence,
by picking the smallest values from each source (as defined by the provided
{@link Comparator}). This is not a {@link #sort(Comparator)}, as it doesn't consider
the whole of each sequences.
<p>
Instead, this operator considers only one value from each source and picks the
smallest of all these values, then replenishes the slot for that picked source.
<p>
<img class="marble" src="doc-files/marbles/mergeOrdered.svg" alt="">

@param comparator the {@link Comparator} to use to find the smallest value
@param sources {@link Publisher} sources to merge
@param <T> the merged type
@return a merged {@link Flux} that , subscribing early but keeping the original ordering