reactor.core.publisher

Class Hooks

java.lang.Object

reactor.core.publisher.Hooks

public abstract class Hooks
extends Object

Allows for various lifecycle override

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) Set a global "assembly" hook 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 either data driven exception or error driven 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 dropped error Consumer hook

onNextDropped

public static void onNextDropped(Consumer<Object> c)

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

Parameters:

c - the dropped next Consumer hook

onOperator

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

Set a global "assembly" hook to intercept signals produced by the passed Publisher (Flux or Mono). The passed function must result in a value different from null, and Hooks.OperatorHook.ignore() can be used to discard a specific Publisher from transformations.

Can be reset via resetOnOperator()

Type Parameters:

T - the arbitrary assembled sequence type

Parameters:

onOperator - a callback for each assembly that must return an Hooks.OperatorHook query

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 - the operator error BiFunction mapper, given the failure and an eventual original context (data or error) and returning an arbitrary exception.

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 either data driven exception or error driven exception.