From cd7f54c926007cee093a98fac71b1f6ffe51b872 Mon Sep 17 00:00:00 2001
From: Julien Ponge <jponge@redhat.com>
Date: Mon, 7 Dec 2020 22:07:32 +0100
Subject: [PATCH] ContextPropagationUniInterceptor fix to UniSubscriber

---
 .../mutiny/context/ContextPropagationUniInterceptor.java       | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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 <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));
             }
         };