Uses of Interface
reactor.util.context.Context

Packages that use Context

Package	Description
reactor.core	Core components of the framework supporting extensions to the Reactive Stream programming model.
reactor.core.observability
reactor.core.publisher	Provide main Reactive APIs in Flux and Mono, as well as various helper classes, interfaces used in the composition API, variants of Flux and operator-building utilities.
reactor.test	Main test components supporting the testing and assertion of publishers.
reactor.util.context	Miscellaneous utility classes, such as loggers, tuples or queue suppliers and implementations.

Uses of Context in reactor.core

Methods in reactor.core that return Context

Modifier and Type	Method and Description
default Context	CoreSubscriber.currentContext() Request a Context from dependent components which can include downstream operators during subscribing or a terminal Subscriber.

Uses of Context in reactor.core.observability

Methods in reactor.core.observability that return Context

Modifier and Type	Method and Description
default Context	SignalListener.addToContext(Context originalContext) In some cases, the tap operation should alter the Context exposed by the operator in order to store additional data.

Methods in reactor.core.observability with parameters of type Context

Modifier and Type	Method and Description
default Context	SignalListener.addToContext(Context originalContext) In some cases, the tap operation should alter the Context exposed by the operator in order to store additional data.

Uses of Context in reactor.core.publisher

Methods in reactor.core.publisher that return Context

Modifier and Type	Method and Description
Context	ReplayProcessor.currentContext() Deprecated.
Context	DirectProcessor.currentContext() Deprecated.
Context	UnicastProcessor.currentContext() Deprecated.
Context	FluxSink.currentContext() Deprecated. To be removed in 3.6.0 at the earliest. Prefer using #contextView() instead.
Context	EmitterProcessor.currentContext() Deprecated.
Context	FluxProcessor.currentContext() Deprecated.
Context	MonoProcessor.currentContext() Deprecated.
Context	SynchronousSink.currentContext() Deprecated. To be removed in 3.6.0 at the earliest. Prefer using #contextView() instead.
Context	MonoSink.currentContext() Deprecated. To be removed in 3.6.0 at the earliest. Prefer using #contextView() instead.
static Context	Operators.enableOnDiscard(Context target, Consumer<?> discardConsumer) Utility method to activate the onDiscard feature (see Flux.doOnDiscard(Class, Consumer)) in a target Context.

Methods in reactor.core.publisher with parameters of type Context

Modifier and Type	Method and Description
static <T> Signal<T>	Signal.complete(Context context) Creates and returns a Signal of variety Type.COMPLETE, associated with a specific Context.
static Context	Operators.enableOnDiscard(Context target, Consumer<?> discardConsumer) Utility method to activate the onDiscard feature (see Flux.doOnDiscard(Class, Consumer)) in a target Context.
static <T> Signal<T>	Signal.error(Throwable e, Context context) Creates and returns a Signal of variety Type.FAILED, which holds the error and the Context associated with the erroring source.
static <T> Signal<T>	Signal.next(T t, Context context) Creates and returns a Signal of variety Type.NEXT, which holds the value and the Context associated with the emitting source.
static <T> void	Operators.onDiscard(T element, Context context) Invoke a (local or global) hook that processes elements that get discarded.
static void	Operators.onDiscardMultiple(Collection<?> multiple, Context context) Invoke a (local or global) hook that processes elements that get discarded en masse.
static void	Operators.onDiscardMultiple(Iterator<?> multiple, boolean knownToBeFinite, Context context) Invoke a (local or global) hook that processes elements that remains in an Iterator.
static void	Operators.onDiscardMultiple(Spliterator<?> multiple, boolean knownToBeFinite, Context context) Invoke a (local or global) hook that processes elements that remains in an Spliterator.
static void	Operators.onDiscardMultiple(Stream<?> multiple, Context context) Invoke a (local or global) hook that processes elements that get discarded en masse.
static <T> void	Operators.onDiscardQueueWithClear(Queue<T> queue, Context context, Function<T,Stream<?>> extract) Invoke a (local or global) hook that processes elements that get discarded en masse after having been enqueued, due to cancellation or error.
static void	Operators.onErrorDropped(Throwable e, Context context) An unexpected exception is about to be dropped.
static <T> void	Operators.onNextDropped(T t, Context context) An unexpected event is about to be dropped.
static <T> Throwable	Operators.onNextError(T value, Throwable error, Context context) Find the OnNextFailureStrategy to apply to the calling async operator (which could be a local error mode defined in the Context) and apply it.
static <T> Throwable	Operators.onNextError(T value, Throwable error, Context context, Subscription subscriptionForCancel) Find the OnNextFailureStrategy to apply to the calling operator (which could be a local error mode defined in the Context) and apply it.
static BiFunction<? super Throwable,Object,? extends Throwable>	Operators.onNextErrorFunction(Context context)
static <T> Throwable	Operators.onNextInnerError(Throwable error, Context context, Subscription subscriptionForCancel) Find the OnNextFailureStrategy to apply to the calling operator (which could be a local error mode defined in the Context) and apply it.
static <T> RuntimeException	Operators.onNextPollError(T value, Throwable error, Context context) Find the OnNextFailureStrategy to apply to the calling async operator (which could be a local error mode defined in the Context) and apply it.
static Throwable	Operators.onOperatorError(Subscription subscription, Throwable error, Context context) Map an "operator" error given an operator parent Subscription.
static Throwable	Operators.onOperatorError(Subscription subscription, Throwable error, Object dataSignal, Context context) Map an "operator" error given an operator parent Subscription.
static Throwable	Operators.onOperatorError(Throwable error, Context context) Map an "operator" error.
static RuntimeException	Operators.onRejectedExecution(Throwable original, Context context) Return a wrapped RejectedExecutionException which can be thrown by the operator.
static RuntimeException	Operators.onRejectedExecution(Throwable original, Subscription subscription, Throwable suppressed, Object dataSignal, Context context) Return a wrapped RejectedExecutionException which can be thrown by the operator.
Disposable	Flux.subscribe(Consumer<? super T> consumer, Consumer<? super Throwable> errorConsumer, Runnable completeConsumer, Context initialContext) Subscribe Consumer to this Flux that will respectively consume all the elements in the sequence, handle errors and react to completion.
Disposable	ParallelFlux.subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Runnable onComplete, Context initialContext) Subscribes to this ParallelFlux by providing an onNext, onError and onComplete callback as well as an initial Context, then trigger the execution chain for all 'rails'.
Disposable	Mono.subscribe(Consumer<? super T> consumer, Consumer<? super Throwable> errorConsumer, Runnable completeConsumer, Context initialContext) Subscribe Consumer to this Mono that will respectively consume all the elements in the sequence, handle errors and react to completion.
static <T> Signal<T>	Signal.subscribe(Subscription subscription, Context context) Creates and returns a Signal of variety Type.ON_SUBSCRIBE, that holds the Context associated with the subscribed source.

Method parameters in reactor.core.publisher with type arguments of type Context

Modifier and Type	Method and Description
Flux<T>	Flux.contextWrite(Function<Context,Context> contextModifier) Enrich the Context visible from downstream for the benefit of upstream operators, by applying a Function to the downstream Context.
Flux<T>	Flux.contextWrite(Function<Context,Context> contextModifier) Enrich the Context visible from downstream for the benefit of upstream operators, by applying a Function to the downstream Context.
Mono<T>	Mono.contextWrite(Function<Context,Context> contextModifier) Enrich the Context visible from downstream for the benefit of upstream operators, by applying a Function to the downstream Context.
Mono<T>	Mono.contextWrite(Function<Context,Context> contextModifier) Enrich the Context visible from downstream for the benefit of upstream operators, by applying a Function to the downstream Context.

Uses of Context in reactor.test

Methods in reactor.test that return Context

Modifier and Type	Method and Description
Context	StepVerifierOptions.getInitialContext()

Methods in reactor.test with parameters of type Context

Modifier and Type	Method and Description
StepVerifier.ContextExpectations<T>	StepVerifier.ContextExpectations.containsAllOf(Context other) Check that the propagated Context contains all of the key-value pairs of the given Context.
StepVerifier.ContextExpectations<T>	StepVerifier.ContextExpectations.containsOnly(Context other) Check that the propagated Context contains all of the key-value pairs of the given Context, and nothing else.
StepVerifierOptions	StepVerifierOptions.withInitialContext(Context context) Set an initial Context to be propagated by the StepVerifier when it subscribes to the sequence under test.

Method parameters in reactor.test with type arguments of type Context

Modifier and Type	Method and Description
StepVerifier.ContextExpectations<T>	StepVerifier.ContextExpectations.assertThat(Consumer<Context> assertingConsumer) Apply custom assertions to the propagated Context.
StepVerifier.ContextExpectations<T>	StepVerifier.ContextExpectations.matches(Predicate<Context> predicate) Check that the propagated Context matches a given Predicate.
StepVerifier.ContextExpectations<T>	StepVerifier.ContextExpectations.matches(Predicate<Context> predicate, String description) Check that the propagated Context matches a given Predicate that is given a description.

Uses of Context in reactor.util.context

Methods in reactor.util.context that return Context

Modifier and Type	Method and Description
Context	Context.delete(Object key) Return a new Context that will resolve all existing keys except the removed one, key.
static Context	Context.empty() Return an empty Context
static Context	Context.of(ContextView contextView) Create a Context out of a ContextView, enabling write API on top of the read-only view.
static Context	Context.of(Map<?,?> map) Create a Context out of a Map.
static Context	Context.of(Object key, Object value) Create a Context pre-initialized with one key-value pair.
static Context	Context.of(Object key1, Object value1, Object key2, Object value2) Create a Context pre-initialized with two key-value pairs.
static Context	Context.of(Object key1, Object value1, Object key2, Object value2, Object key3, Object value3) Create a Context pre-initialized with three key-value pairs.
static Context	Context.of(Object key1, Object value1, Object key2, Object value2, Object key3, Object value3, Object key4, Object value4) Create a Context pre-initialized with four key-value pairs.
static Context	Context.of(Object key1, Object value1, Object key2, Object value2, Object key3, Object value3, Object key4, Object value4, Object key5, Object value5) Create a Context pre-initialized with five key-value pairs.
Context	Context.put(Object key, Object value) Create a new Context that contains all current key/value pairs plus the given key/value pair.
default Context	Context.putAll(Context context) Deprecated. will be removed in 3.5, kept for backward compatibility with 3.3. Until then if you need to work around the deprecation, use putAll(ContextView) combined with readOnly()
default Context	Context.putAll(ContextView other) Create a new Context by merging the content of this context and a given ContextView.
default Context	Context.putAllMap(Map<?,?> from) Create a new Context by merging the content of this context and a given Map.
default Context	Context.putNonNull(Object key, Object valueOrNull) Create a new Context that contains all current key/value pairs plus the given key/value pair only if the value is not null.
Context	ReactorContextAccessor.writeValues(Map<Object,Object> source, Context target)

Methods in reactor.util.context that return types with arguments of type Context

Modifier and Type	Method and Description
Class<? extends Context>	ReactorContextAccessor.writeableType()

Methods in reactor.util.context with parameters of type Context

Modifier and Type	Method and Description
default Context	Context.putAll(Context context) Deprecated. will be removed in 3.5, kept for backward compatibility with 3.3. Until then if you need to work around the deprecation, use putAll(ContextView) combined with readOnly()
Context	ReactorContextAccessor.writeValues(Map<Object,Object> source, Context target)