Uses of Interface
reactor.util.context.ContextView

Packages that use ContextView

Package	Description
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.subscriber	Components supporting the creation of test-oriented Subscribers.
reactor.util.context	Miscellaneous utility classes, such as loggers, tuples or queue suppliers and implementations.
reactor.util.retry

Uses of ContextView in reactor.core.observability

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

Modifier and Type	Method and Description
SignalListener<T>	SignalListenerFactory.createListener(Publisher<? extends T> source, ContextView listenerContext, STATE publisherContext) Create a new SignalListener each time a new Subscriber subscribes to the source Publisher.

Uses of ContextView in reactor.core.publisher

Methods in reactor.core.publisher that return ContextView

Modifier and Type	Method and Description
default ContextView	FluxSink.contextView() Return the current subscriber's context as a ContextView for inspection.
default ContextView	SynchronousSink.contextView() Return the current subscriber's context as a ContextView for inspection.
default ContextView	MonoSink.contextView() Return the current subscriber's context as a ContextView for inspection.
ContextView	Signal.getContextView() Return the readonly ContextView that is accessible by the time this Signal was emitted.

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

Modifier and Type	Method and Description
Flux<T>	Flux.contextWrite(ContextView contextToAppend) Enrich the Context visible from downstream for the benefit of upstream operators, by making all values from the provided ContextView visible on top of pairs from downstream.
Mono<T>	Mono.contextWrite(ContextView contextToAppend) Enrich the Context visible from downstream for the benefit of upstream operators, by making all values from the provided ContextView visible on top of pairs from downstream.

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

Modifier and Type	Method and Description
static <T> Mono<T>	Mono.deferContextual(Function<ContextView,? extends Mono<? extends T>> contextualMonoFactory) Create a Mono provider that will supply a target Mono to subscribe to for each Subscriber downstream.
static <T> Flux<T>	Flux.deferContextual(Function<ContextView,? extends Publisher<T>> contextualPublisherFactory) Lazily supply a Publisher every time a Subscription is made on the resulting Flux, so the actual source instantiation is deferred until each subscribe and the Function can create a subscriber-specific instance.
Flux<T>	Flux.tap(Function<ContextView,SignalListener<T>> listenerGenerator) Tap into Reactive Streams signals emitted or received by this Flux and notify a stateful per-Subscriber SignalListener.
Mono<T>	Mono.tap(Function<ContextView,SignalListener<T>> listenerGenerator) Tap into Reactive Streams signals emitted or received by this Mono and notify a stateful per-Subscriber SignalListener.
<V> Flux<V>	Flux.transformDeferredContextual(BiFunction<? super Flux<T>,? super ContextView,? extends Publisher<V>> transformer) Defer the given transformation to this Flux in order to generate a target Flux type.
<V> Mono<V>	Mono.transformDeferredContextual(BiFunction<? super Mono<T>,? super ContextView,? extends Publisher<V>> transformer) Defer the given transformation to this Mono in order to generate a target Mono type.

Uses of ContextView in reactor.test.subscriber

Methods in reactor.test.subscriber with parameters of type ContextView

Modifier and Type	Method and Description
TestSubscriberBuilder	TestSubscriberBuilder.contextPutAll(ContextView toAdd) Enrich the Context by putting all entries of the given ContextView in it.

Uses of ContextView in reactor.util.context

Subinterfaces of ContextView in reactor.util.context

Modifier and Type	Interface and Description
interface	Context A key/value store that is propagated between components such as operators via the context protocol.

Methods in reactor.util.context that return ContextView

Modifier and Type	Method and Description
default ContextView	Context.readOnly() Switch to the ContextView interface, which only allows reading from the context.

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

Modifier and Type	Method and Description
Class<? extends ContextView>	ReactorContextAccessor.readableType()

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

Modifier and Type	Method and Description
static Context	Context.of(ContextView contextView) Create a Context out of a ContextView, enabling write API on top of the read-only view.
default Context	Context.putAll(ContextView other) Create a new Context by merging the content of this context and a given ContextView.
<T> T	ReactorContextAccessor.readValue(ContextView sourceContext, Object key)
void	ReactorContextAccessor.readValues(ContextView source, Predicate<Object> keyPredicate, Map<Object,Object> target)

Uses of ContextView in reactor.util.retry

Fields in reactor.util.retry declared as ContextView

Modifier and Type	Field and Description
ContextView	Retry.retryContext

Methods in reactor.util.retry that return ContextView

Modifier and Type	Method and Description
ContextView	Retry.retryContext() Return the user provided context that was set at construction time.
default ContextView	Retry.RetrySignal.retryContextView() Return a read-only view of the user provided context, which may be used to store objects to be reset/rolled-back or otherwise mutated before or after a retry.

Methods in reactor.util.retry with parameters of type ContextView

Modifier and Type	Method and Description
RetrySpec	RetrySpec.withRetryContext(ContextView retryContext) Set the user provided context that can be used to manipulate state on retries.
RetryBackoffSpec	RetryBackoffSpec.withRetryContext(ContextView retryContext) Set the user provided context that can be used to manipulate state on retries.

Constructors in reactor.util.retry with parameters of type ContextView

Constructor and Description
Retry(ContextView retryContext)