reactor.util.context

Class ReactorContextAccessor

java.lang.Object

reactor.util.context.ReactorContextAccessor

All Implemented Interfaces:

io.micrometer.context.ContextAccessor<ContextView,Context>

public final class ReactorContextAccessor
extends java.lang.Object
implements io.micrometer.context.ContextAccessor<ContextView,Context>

A ContextAccessor to enable reading values from a Reactor ContextView and writing values to Context.

Please note that this public class implements the libs.micrometer.contextPropagation SPI library, which is an optional dependency.

Since:

3.5.0

Author:

Rossen Stoyanchev, Simon Baslé

Constructor Summary

Constructors

Constructor and Description
ReactorContextAccessor()

Method Summary

Modifier and Type	Method and Description
java.lang.Class<? extends ContextView>	readableType()
<T> T	readValue(ContextView sourceContext, java.lang.Object key)
void	readValues(ContextView source, java.util.function.Predicate<java.lang.Object> keyPredicate, java.util.Map<java.lang.Object,java.lang.Object> target)
java.lang.Class<? extends Context>	writeableType()
Context	writeValues(java.util.Map<java.lang.Object,java.lang.Object> source, Context target)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactorContextAccessor

public ReactorContextAccessor()

Method Detail

readableType

public java.lang.Class<? extends ContextView> readableType()

Specified by:

readableType in interface io.micrometer.context.ContextAccessor<ContextView,Context>

readValues

public void readValues(ContextView source,
                       java.util.function.Predicate<java.lang.Object> keyPredicate,
                       java.util.Map<java.lang.Object,java.lang.Object> target)

Specified by:

readValues in interface io.micrometer.context.ContextAccessor<ContextView,Context>

readValue

@Nullable
public <T> T readValue(ContextView sourceContext,
                                 java.lang.Object key)

Specified by:

readValue in interface io.micrometer.context.ContextAccessor<ContextView,Context>

writeableType

public java.lang.Class<? extends Context> writeableType()

Specified by:

writeableType in interface io.micrometer.context.ContextAccessor<ContextView,Context>

writeValues

public Context writeValues(java.util.Map<java.lang.Object,java.lang.Object> source,
                           Context target)

Specified by:

writeValues in interface io.micrometer.context.ContextAccessor<ContextView,Context>