Merge pull request quarkusio#22161 from quarkusio/fix/grpc-devmode-te…

…st-bad-mutiny-usage Fix incorrect Mutiny subscription APIs
gastaldi · Dec 13, 2021 · c7241e7 · c7241e7
2 parents ab382fe + dc03bdf
commit c7241e7
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/devmode/GrpcDevModeTest.java b/extensions/grpc/deployment/src/test/java/io/quarkus/grpc/server/devmode/GrpcDevModeTest.java
@@ -30,7 +30,6 @@
 import io.grpc.examples.helloworld.HelloRequest;
 import io.quarkus.test.QuarkusDevModeTest;
 import io.smallrye.mutiny.Multi;
-import io.smallrye.mutiny.subscription.Subscribers;
 
 public class GrpcDevModeTest {
     @RegisterExtension
@@ -135,14 +134,14 @@ private CompletionStage<Boolean> callEcho(String name, List<String> output) {
                 .map(StreamsOuterClass.Item.Builder::build);
         Multi<StreamsOuterClass.Item> echo = MutinyStreamsGrpc.newMutinyStub(channel)
                 .echo(request);
-        echo.subscribe().withSubscriber(Subscribers.from(
+        echo.subscribe().with(
+                s -> s.request(Long.MAX_VALUE),
                 item -> output.add(item.getName()),
                 error -> {
                     error.printStackTrace();
                     result.completeExceptionally(error);
                 },
-                () -> result.complete(true),
-                s -> s.request(Long.MAX_VALUE)));
+                () -> result.complete(true));
         return result;
     }