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 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
boolean	canReadFrom(Class<?> contextType)
boolean	canWriteTo(Class<?> contextType)
<T> T	readValue(ContextView sourceContext, Object key)
void	readValues(ContextView source, Predicate<Object> keyPredicate, Map<Object,Object> target)
Context	writeValues(Map<Object,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

canReadFrom

public boolean canReadFrom(Class<?> contextType)

Specified by:

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

readValues

public void readValues(ContextView source,
                       Predicate<Object> keyPredicate,
                       Map<Object,Object> target)

Specified by:

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

readValue

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

Specified by:

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

canWriteTo

public boolean canWriteTo(Class<?> contextType)

Specified by:

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

writeValues

public Context writeValues(Map<Object,Object> source,
                           Context target)

Specified by:

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