reactor.core.publisher

Class Hooks

java.lang.Object

reactor.core.publisher.Hooks

public abstract class Hooks
extends Object

A set of overridable lifecycle hooks that can be used for cross-cutting added behavior on Flux/Mono operators.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Hooks.OperatorHook<T> Filtering and Handling options to apply on a given Publisher

Method Summary

Modifier and Type	Method and Description
static void	onErrorDropped(Consumer<? super Throwable> c) Override global error dropped strategy which by default bubble back the error.
static void	onNextDropped(Consumer<Object> c) Override global data dropped strategy which by default throw Exceptions.failWithCancel()
static <T> void	onOperator(Function<? super Hooks.OperatorHook<T>,? extends Hooks.OperatorHook<T>> onOperator) Configure a global chain of "assembly" hooks to intercept signals produced by the passed Publisher (Flux or Mono).
static void	onOperatorError(BiFunction<? super Throwable,Object,? extends Throwable> f) Override global operator error mapping which by default add as suppressed exception either data driven exception or error driven exception.
static void	resetOnErrorDropped() Reset global error dropped strategy to bubbling back the error.
static void	resetOnNextDropped() Reset global data dropped strategy to throwing via Exceptions.failWithCancel()
static void	resetOnOperator() Reset global "assembly" hook tracking
static void	resetOnOperatorError() Reset global operator error mapping to adding as suppressed exception.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

onErrorDropped

public static void onErrorDropped(Consumer<? super Throwable> c)

Override global error dropped strategy which by default bubble back the error.

Parameters:

c - the Consumer to apply to dropped errors

onNextDropped

public static void onNextDropped(Consumer<Object> c)

Override global data dropped strategy which by default throw Exceptions.failWithCancel()

Parameters:

c - the Consumer to apply to data (onNext) that is dropped

onOperator

public static <T> void onOperator(Function<? super Hooks.OperatorHook<T>,? extends Hooks.OperatorHook<T>> onOperator)

Configure a global chain of "assembly" hooks to intercept signals produced by the passed Publisher (Flux or Mono). The passed function provides a base Hooks.OperatorHook that can be used as a kind of builder to compose several hooks or behaviors (eg. transverse logging). Hooks.OperatorHook.ignore() can be used to prevent all hooks from applying to a specific Publisher.

Can be reset via resetOnOperator()

Type Parameters:

T - the arbitrary assembled sequence type

Parameters:

onOperator - a callback for each assembly that must return a non-null Hooks.OperatorHook

onOperatorError

public static void onOperatorError(BiFunction<? super Throwable,Object,? extends Throwable> f)

Override global operator error mapping which by default add as suppressed exception either data driven exception or error driven exception.

Parameters:

f - an operator error BiFunction mapper, returning an arbitrary exception given the failure and optionally some original context (data or error).

resetOnErrorDropped

public static void resetOnErrorDropped()

Reset global error dropped strategy to bubbling back the error.

resetOnNextDropped

public static void resetOnNextDropped()

Reset global data dropped strategy to throwing via Exceptions.failWithCancel()

resetOnOperator

public static void resetOnOperator()

Reset global "assembly" hook tracking

resetOnOperatorError

public static void resetOnOperatorError()

Reset global operator error mapping to adding as suppressed exception.