static <T> void afterCompleteWithFailure(SignalPeek<T> parent,
			Throwable callbackFailure, Context context) {

		Exceptions.throwIfFatal(callbackFailure);
		Throwable _e = Operators.onOperatorError(callbackFailure, context);
		Operators.onErrorDropped(_e, context);
	}
static <T> void afterCompleteWithFailure(SignalPeek<T> parent,
			Throwable callbackFailure, Context context) {

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