org.springframework.graphql.execution

Class ReactorContextManager

java.lang.Object

org.springframework.graphql.execution.ReactorContextManager

public abstract class ReactorContextManager
extends Object

Provides helper methods to save Reactor context in the GraphQLContext so it can be subsequently obtained and propagated to data fetchers, exception handlers, and others.

The Reactor context is also used to carry ThreadLocal values that are also restored around the execution of data fetchers and exceptions handlers.

Since:

1.0.0

Author:

Rossen Stoyanchev

Constructor Summary

Constructors

Constructor and Description
ReactorContextManager()

Method Summary

Modifier and Type	Method and Description
static reactor.util.context.Context	extractThreadLocalValues(ThreadLocalAccessor accessor, reactor.util.context.Context context) Use the given accessor to extract ThreadLocal values and save them in a sub-map in the given Context, so those can be restored later around the execution of data fetchers and exception resolvers.
static <T> T	invokeCallable(Callable<T> callable, GraphQLContext graphQlContext) Restore ThreadLocal values, invoke the given Callable, and reset the ThreadLocal values.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactorContextManager

public ReactorContextManager()

Method Detail

extractThreadLocalValues

public static reactor.util.context.Context extractThreadLocalValues(ThreadLocalAccessor accessor,
                                                                    reactor.util.context.Context context)

Use the given accessor to extract ThreadLocal values and save them in a sub-map in the given Context, so those can be restored later around the execution of data fetchers and exception resolvers. The accessor instance is also saved in the Reactor Context, so it can be used to actually restore and reset ThreadLocal values.

Parameters:

accessor - the accessor to use

context - the context to write to if there are ThreadLocal values

Returns:

a new Reactor ContextView or the Context instance that was passed in, if there were no ThreadLocal values to extract.

invokeCallable

public static <T> T invokeCallable(Callable<T> callable,
                                   GraphQLContext graphQlContext)
                            throws Exception

Restore ThreadLocal values, invoke the given Callable, and reset the ThreadLocal values.

Parameters:

callable - the callable to invoke

graphQlContext - the current GraphQLContext

Returns:

the return value from the invocation

Throws:

Exception