Top Description Fields Constructors Methods

reactor.core.publisher

pack-priv Class ContextTrackingFunctionWrapper<T, V>

Class Inheritance

extends Object
implements Function<Publisher<T>, CorePublisher<V>>

java.lang.Object
reactor.core.publisher.ContextTrackingFunctionWrapper

All Implemented Interfaces

java.util.function.Function

Imports

java.util.function.Function, org.reactivestreams.Publisher, .Subscriber, reactor.core.CorePublisher, .CoreSubscriber, reactor.core.publisher.FluxContextWrite.ContextWriteSubscriber, reactor.util.context.Context

This Function wrapper is used by operators like Flux#transform(Function) to implement the context loss detection.

Field Summary

Modifier and Type	Field and Description
pack-priv static final String	CONTEXT_MARKER_PREFIX
pack-priv final String	marker
pack-priv final Function<? super Publisher<T>, ? extends Publisher<V>>	transformer

Constructor Summary

Access	Constructor and Description
pack-priv	ContextTrackingFunctionWrapper(Function<? super Publisher<T>, ? extends Publisher<V>> transformer)
pack-priv	ContextTrackingFunctionWrapper(Function<? super Publisher<T>, ? extends Publisher<V>> transformer, String marker)

Method Summary

Modifier and Type	Method and Description
public CorePublisher<V>	apply(Publisher<T> the function argument source) Implements java.util.function.Function.apply. Applies this function to the given argument.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

CONTEXT_MARKER_PREFIX	back to summary
pack-priv static final String CONTEXT_MARKER_PREFIX

marker	back to summary
pack-priv final String marker

transformer	back to summary
pack-priv final Function<? super Publisher<T>, ? extends Publisher<V>> transformer

Constructor Detail

ContextTrackingFunctionWrapper	back to summary
pack-priv ContextTrackingFunctionWrapper(Function<? super Publisher<T>, ? extends Publisher<V>> transformer)

ContextTrackingFunctionWrapper	back to summary
pack-priv ContextTrackingFunctionWrapper(Function<? super Publisher<T>, ? extends Publisher<V>> transformer, String marker)

Method Detail

apply

back to summary

public CorePublisher<V> apply(Publisher<T> source)

Implements java.util.function.Function.apply.

Doc from java.util.function.Function.apply.

Applies this function to the given argument.

Parameters

source:Publisher<T>: the function argument

Returns:CorePublisher<V>

the function result

Annotations

@Override