reactor-core/src/main/java/reactor/core/publisher/FluxPeek.java
static <T> void afterErrorWithFailure(SignalPeek<T> parent,
			Throwable callbackFailure, Throwable originalError, Context context) {
		Exceptions.throwIfFatal(callbackFailure);
		Throwable _e = Operators.onOperatorError(null, callbackFailure, originalError, context);
		Operators.onErrorDropped(_e, context);
	}
static <T> void afterErrorWithFailure(SignalPeek<T> parent,
			Throwable callbackFailure, Throwable originalError, Context context) {
		Exceptions.throwIfFatal(callbackFailure);
		Throwable _e = Operators.onOperatorError(null, callbackFailure, originalError, context);
		Operators.onErrorDropped(_e, context);
	}
static < T > void afterErrorWithFailure ( SignalPeek < T > parent , Throwable callbackFailure , Throwable originalError , Context context ) { Exceptions . throwIfFatal ( callbackFailure ) ; Throwable _e = Operators . onOperatorError ( null , callbackFailure , originalError , context ) ; Operators . onErrorDropped ( _e , context ) ; }
see https://github.com/reactor/reactor-core/issues/270
see https : // github . com / reactor / reactor - core / issues / 270