public class ContextServiceImpl
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
class |
ContextServiceImpl.Snapshot |
class |
ContextServiceImpl.State |
| Constructor and Description |
|---|
ContextServiceImpl() |
| Modifier and Type | Method and Description |
|---|---|
<R> java.util.concurrent.Callable<R> |
contextualCallable(java.util.concurrent.Callable<R> callable) |
<T,U> java.util.function.BiConsumer<T,U> |
contextualConsumer(java.util.function.BiConsumer<T,U> biConsumer) |
<T> java.util.function.Consumer<T> |
contextualConsumer(java.util.function.Consumer<T> consumer) |
<T,U,R> java.util.function.BiFunction<T,U,R> |
contextualFunction(java.util.function.BiFunction<T,U,R> biFunction) |
<T,R> java.util.function.Function<T,R> |
contextualFunction(java.util.function.Function<T,R> function) |
java.lang.Runnable |
contextualRunnable(java.lang.Runnable runnable) |
<R> java.util.function.Supplier<R> |
contextualSupplier(java.util.function.Supplier<R> supplier) |
java.lang.Object |
createContextualProxy(java.lang.Object instance,
java.lang.Class<?>... interfaces) |
java.lang.Object |
createContextualProxy(java.lang.Object instance,
java.util.Map<java.lang.String,java.lang.String> executionProperties,
java.lang.Class<?>... interfaces) |
<T> T |
createContextualProxy(T instance,
java.lang.Class<T> intf) |
<T> T |
createContextualProxy(T instance,
java.util.Map<java.lang.String,java.lang.String> executionProperties,
java.lang.Class<T> intf) |
java.util.concurrent.Executor |
currentContextExecutor() |
ContextServiceImpl.State |
enter(ContextServiceImpl.Snapshot snapshot) |
void |
exit(ContextServiceImpl.State state) |
java.util.List<ThreadContextProvider> |
getCleared() |
java.util.Map<java.lang.String,java.lang.String> |
getExecutionProperties(java.lang.Object contextualProxy) |
java.util.List<ThreadContextProvider> |
getPropagated() |
java.util.List<ThreadContextProvider> |
getUnchanged() |
ContextServiceImpl.Snapshot |
snapshot(java.util.Map<java.lang.String,java.lang.String> props) |
<T> java.util.concurrent.CompletableFuture<T> |
withContextCapture(java.util.concurrent.CompletableFuture<T> completableFuture) |
<T> java.util.concurrent.CompletionStage<T> |
withContextCapture(java.util.concurrent.CompletionStage<T> completionStage) |
public java.util.List<ThreadContextProvider> getPropagated()
public java.util.List<ThreadContextProvider> getCleared()
public java.util.List<ThreadContextProvider> getUnchanged()
public <R> java.util.concurrent.Callable<R> contextualCallable(java.util.concurrent.Callable<R> callable)
public <T,U> java.util.function.BiConsumer<T,U> contextualConsumer(java.util.function.BiConsumer<T,U> biConsumer)
public <T> java.util.function.Consumer<T> contextualConsumer(java.util.function.Consumer<T> consumer)
public <T,U,R> java.util.function.BiFunction<T,U,R> contextualFunction(java.util.function.BiFunction<T,U,R> biFunction)
public <T,R> java.util.function.Function<T,R> contextualFunction(java.util.function.Function<T,R> function)
public java.lang.Runnable contextualRunnable(java.lang.Runnable runnable)
public <R> java.util.function.Supplier<R> contextualSupplier(java.util.function.Supplier<R> supplier)
public <T> T createContextualProxy(T instance,
java.lang.Class<T> intf)
public java.lang.Object createContextualProxy(java.lang.Object instance,
java.lang.Class<?>... interfaces)
public <T> T createContextualProxy(T instance,
java.util.Map<java.lang.String,java.lang.String> executionProperties,
java.lang.Class<T> intf)
public java.lang.Object createContextualProxy(java.lang.Object instance,
java.util.Map<java.lang.String,java.lang.String> executionProperties,
java.lang.Class<?>... interfaces)
public java.util.concurrent.Executor currentContextExecutor()
public java.util.Map<java.lang.String,java.lang.String> getExecutionProperties(java.lang.Object contextualProxy)
public <T> java.util.concurrent.CompletableFuture<T> withContextCapture(java.util.concurrent.CompletableFuture<T> completableFuture)
public <T> java.util.concurrent.CompletionStage<T> withContextCapture(java.util.concurrent.CompletionStage<T> completionStage)
public ContextServiceImpl.Snapshot snapshot(java.util.Map<java.lang.String,java.lang.String> props)
public ContextServiceImpl.State enter(ContextServiceImpl.Snapshot snapshot)
public void exit(ContextServiceImpl.State state)