diff --git a/context-propagation/src/main/java/io/smallrye/mutiny/context/ContextPropagationUniInterceptor.java b/context-propagation/src/main/java/io/smallrye/mutiny/context/ContextPropagationUniInterceptor.java index 4895d3caa..29164995e 100644 --- a/context-propagation/src/main/java/io/smallrye/mutiny/context/ContextPropagationUniInterceptor.java +++ b/context-propagation/src/main/java/io/smallrye/mutiny/context/ContextPropagationUniInterceptor.java @@ -7,7 +7,6 @@ import io.smallrye.mutiny.Uni; import io.smallrye.mutiny.infrastructure.UniInterceptor; import io.smallrye.mutiny.operators.AbstractUni; -import io.smallrye.mutiny.operators.UniSerializedSubscriber; import io.smallrye.mutiny.subscription.UniSubscriber; import io.smallrye.mutiny.subscription.UniSubscription; @@ -44,7 +43,7 @@ public Uni onUniCreation(Uni uni) { Executor executor = getThreadContext().currentContextExecutor(); return new AbstractUni() { @Override - protected void subscribing(UniSerializedSubscriber subscriber) { + protected void subscribing(UniSubscriber subscriber) { executor.execute(() -> AbstractUni.subscribe(uni, subscriber)); } };