Skip to content

Commit

Permalink
Merge pull request #443 from smallrye/fix-uni-directsubscription
Browse files Browse the repository at this point in the history
  • Loading branch information
cescoffier authored Jan 14, 2021
2 parents 07df718 + fbd1ec2 commit a24211b
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ public class UniSerializedSubscriber<T> implements UniSubscriber<T>, UniSubscrip
public static <T> void subscribe(AbstractUni<T> source, UniSubscriber<? super T> subscriber) {
UniSubscriber<? super T> actual = Infrastructure.onUniSubscription(source, subscriber);
if (subscriber instanceof UniSerializedSubscriber) {
source.subscribing(subscriber);
source.subscribing(actual);
} else {
UniSerializedSubscriber<T> wrapped = new UniSerializedSubscriber<>(source, actual);
wrapped.subscribe();
Expand Down

0 comments on commit a24211b

Please sign in to comment.