From fbd1ec2353edba295191375729efe6b4782c1e6f Mon Sep 17 00:00:00 2001 From: Julien Ponge Date: Wed, 13 Jan 2021 21:37:38 +0100 Subject: [PATCH] Fix Uni subscription when interceptors are present --- .../io/smallrye/mutiny/operators/UniSerializedSubscriber.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/implementation/src/main/java/io/smallrye/mutiny/operators/UniSerializedSubscriber.java b/implementation/src/main/java/io/smallrye/mutiny/operators/UniSerializedSubscriber.java index 78a145c54..d4f493582 100644 --- a/implementation/src/main/java/io/smallrye/mutiny/operators/UniSerializedSubscriber.java +++ b/implementation/src/main/java/io/smallrye/mutiny/operators/UniSerializedSubscriber.java @@ -46,7 +46,7 @@ public class UniSerializedSubscriber implements UniSubscriber, UniSubscrip public static void subscribe(AbstractUni source, UniSubscriber subscriber) { UniSubscriber actual = Infrastructure.onUniSubscription(source, subscriber); if (subscriber instanceof UniSerializedSubscriber) { - source.subscribing(subscriber); + source.subscribing(actual); } else { UniSerializedSubscriber wrapped = new UniSerializedSubscriber<>(source, actual); wrapped.subscribe();