code: @SafeVarargs
  	public static <T> Flux<T> mergeOrdered(Comparator<? super T> comparator, Publisher<? extends T>... sources) {
  		return mergeOrdered(Queues.SMALL_BUFFER_SIZE, comparator, sources);
  	}
docs: 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