Package 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	Description
ReactorContextAccessor()

Method Summary

Modifier and Type	Method	Description
Class<? extends ContextView>	readableType()
<T> @Nullable T	readValue(ContextView sourceContext, Object key)
void	readValues(ContextView source, Predicate<Object> keyPredicate, Map<Object,Object> target)
Class<? extends Context>	writeableType()
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 Details

ReactorContextAccessor

public ReactorContextAccessor()

Method Details

readableType

public Class<? extends ContextView> readableType()

Specified by:

readableType 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

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

Specified by:

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

writeableType

public Class<? extends Context> writeableType()

Specified by:

writeableType 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>