reactor-core/src/main/java/reactor/core/publisher/Hooks.java
public static void onNextDropped(Consumer<Object> c) {
		Objects.requireNonNull(c, "onNextDroppedHook");
		log.debug("Hooking new default : onNextDropped");

		synchronized(log) {
			if (onNextDroppedHook != null) {
				onNextDroppedHook = onNextDroppedHook.andThen(c);
			}
			else {
				onNextDroppedHook = c;
			}
		}
	}
public static void onNextDropped(Consumer<Object> c) {
		Objects.requireNonNull(c, "onNextDroppedHook");
		log.debug("Hooking new default : onNextDropped");

		synchronized(log) {
			if (onNextDroppedHook != null) {
				onNextDroppedHook = onNextDroppedHook.andThen(c);
			}
			else {
				onNextDroppedHook = c;
			}
		}
	}
public static void onNextDropped ( Consumer < Object > c ) { Objects . requireNonNull ( c , "onNextDroppedHook" ) ; log . debug ( "Hooking new default : onNextDropped" ) ; synchronized ( log ) { if ( onNextDroppedHook != null ) { onNextDroppedHook = onNextDroppedHook . andThen ( c ) ; } else { onNextDroppedHook = c ; } } }
Override global data dropped strategy which by default logs at DEBUG level.
<p>
The hook is cumulative, so calling this method several times will set up the hook
for as many consumer invocations (even if called with the same consumer instance).

@param c the {@link Consumer} to apply to data (onNext) that is dropped
@see #onNextDroppedFail()
Override global data dropped strategy which by default logs at DEBUG level . <p > The hook is cumulative so calling this method several times will set up the hook for as many consumer invocations ( even if called with the same consumer instance ) .