public FluxConcatArray<T> concatAdditionalSourceLast(Publisher<? extends T> source){
  int n=array.length;
  @SuppressWarnings("unchecked") Publisher<? extends T>[] newArray=new Publisher[n + 1];
  System.arraycopy(array,0,newArray,0,n);
  newArray[n]=source;
  return new FluxConcatArray<>(delayError,newArray);
}

public FluxConcatArray < T > concatAdditionalSourceLast ( Publisher < ? extends T > source ) { int n = array . length ; @ SuppressWarnings ( "unchecked" ) Publisher < ? extends T > [ ] newArray = new Publisher [ n + 1 ] ; System . arraycopy ( array , 0 , newArray , 0 , n ) ; newArray [ n ] = source ; return new FluxConcatArray < > ( delayError , newArray ) ; }
returns a new instance which has the additional source to be merged together with the current array of sources . < p > this operation doesn ' t change the current fluxmerge instance .
