public final ParallelFlux<T> doOnNext(Consumer<? super T> onNext){
  Objects.requireNonNull(onNext,"onNext");
  return doOnSignal(this,onNext,null,null,null,null,null,null,null);
}

public final ParallelFlux < T > doOnNext ( Consumer < ? super T > onNext ) { Objects . requireNonNull ( onNext , "onNext" ) ; return doOnSignal ( this , onNext , null , null , null , null , null , null , null ) ; }
call the specified consumer with the current element passing through any ' rail ' .
