diff --git a/spring-core/src/main/java/org/springframework/core/PropagationContextElement.java b/spring-core/src/main/java/org/springframework/core/PropagationContextElement.java index 9a2addad645..d78d2f66ca6 100644 --- a/spring-core/src/main/java/org/springframework/core/PropagationContextElement.java +++ b/spring-core/src/main/java/org/springframework/core/PropagationContextElement.java @@ -78,10 +78,12 @@ public final class PropagationContextElement extends AbstractCoroutineContextEle this.threadLocalContextSnapshot = contextSnapshotFactory.captureAll(); } + @Override public void restoreThreadContext(CoroutineContext context, ContextSnapshot.Scope oldState) { oldState.close(); } + @Override public ContextSnapshot.Scope updateThreadContext(CoroutineContext context) { ContextSnapshot contextSnapshot; if (coroutinesReactorPresent) {