Skip to content

Commit

Permalink
Merge pull request #215 from smallrye/dependabot/maven/mutiny.version…
Browse files Browse the repository at this point in the history
…-0.12.5
  • Loading branch information
cescoffier authored Dec 17, 2020
2 parents 89d5db0 + 35dcb00 commit 4c9637e
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -43,8 +43,8 @@
</scm>

<properties>
<vertx.version>3.9.4</vertx.version>
<mutiny.version>0.11.0</mutiny.version>
<vertx.version>3.9.5</vertx.version>
<mutiny.version>0.12.5</mutiny.version>
<jackson.version>2.12.0</jackson.version>
<reactive-streams.version>1.0.3</reactive-streams.version>

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

import io.smallrye.mutiny.Uni;
import io.smallrye.mutiny.operators.AbstractUni;
import io.smallrye.mutiny.operators.UniSerializedSubscriber;
import io.smallrye.mutiny.subscription.UniSubscriber;
import io.vertx.core.AsyncResult;
import io.vertx.core.Handler;

Expand All @@ -21,7 +21,7 @@ public AsyncResultUni(Consumer<Handler<AsyncResult<T>>> subscriptionConsumer) {
}

@Override
protected void subscribing(UniSerializedSubscriber<? super T> downstream) {
protected void subscribing(UniSubscriber<? super T> downstream) {
AtomicBoolean terminated = new AtomicBoolean();
downstream.onSubscribe(() -> terminated.set(true));

Expand Down

0 comments on commit 4c9637e

Please sign in to comment.