public final ParallelFlux<T> doOnError(Consumer<? super Throwable> onError) {
		Objects.requireNonNull(onError, "onError");
		return doOnSignal(this, null, null, onError, null, null, null, null, null);
	}
public final ParallelFlux<T> doOnError(Consumer<? super Throwable> onError) {
		Objects.requireNonNull(onError, "onError");
		return doOnSignal(this, null, null, onError, null, null, null, null, null);
	}
public final ParallelFlux < T > doOnError ( Consumer < ? super Throwable > onError ) { Objects . requireNonNull ( onError , "onError" ) ; return doOnSignal ( this , null , null , onError , null , null , null , null , null ) ; }
Call the specified consumer with the exception passing through any 'rail'.

@param onError the callback

@return the new {@link ParallelFlux} instance
Call the specified consumer with the exception passing through any rail .