code: public static <T> Flux<T> concatDelayError(Publisher<? extends Publisher<? extends T>> sources) {
  		return concatDelayError(sources, Queues.XS_BUFFER_SIZE);
  	}
docs: Concatenate all sources emitted as an onNext signal from a parent {@link Publisher},
  forwarding elements emitted by the sources downstream.
  <p>
  Concatenation is achieved by sequentially subscribing to the first source then
  waiting for it to complete before subscribing to the next, and so on until the
  last source completes. Errors do not interrupt the main sequence but are propagated
  after the rest of the sources have had a chance to be concatenated.
  <p>
  <img class="marble" src="doc-files/marbles/concatAsyncSources.svg" alt="">
  
  
  @reactor.discard This operator discards elements it internally queued for backpressure upon cancellation.
  
  @param sources The {@link Publisher} of {@link Publisher} to concatenate
  @param <T> The type of values in both source and output sequences
  
  @return a new {@link Flux} concatenating all inner sources sequences, delaying errors