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