ContextPropagationUniInterceptor fix to UniSubscriber

smallrye · Dec 7, 2020 · cd7f54c · cd7f54c
1 parent 9985faf
commit cd7f54c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ropagation/src/main/java/io/smallrye/mutiny/context/ContextPropagationUniInterceptor.java b/...ropagation/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 <T> Uni<T> onUniCreation(Uni<T> uni) {
         Executor executor = getThreadContext().currentContextExecutor();
         return new AbstractUni<T>() {
             @Override
-            protected void subscribing(UniSerializedSubscriber<? super T> subscriber) {
+            protected void subscribing(UniSubscriber<? super T> subscriber) {
                 executor.execute(() -> AbstractUni.subscribe(uni, subscriber));
             }
         };