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

@ SuppressWarnings ( "unchecked" ) public < V > FluxConcatArray < V > concatAdditionalIgnoredLast ( Publisher < ? extends V > source ) { int n = array . length ; Publisher < ? extends V > [ ] newArray = new Publisher [ n + 1 ] ; System . arraycopy ( array , 0 , newArray , 0 , n ) ; newArray [ n - 1 ] = new MonoIgnoreThen < > ( newArray [ n - 1 ] ) ; 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 .
