diff --git a/frameworks/Java/quarkus/reactive-routes-pgclient/src/main/java/io/quarkus/benchmark/resource/DbResource.java b/frameworks/Java/quarkus/reactive-routes-pgclient/src/main/java/io/quarkus/benchmark/resource/DbResource.java index e2533434d24..4237a81f8dc 100644 --- a/frameworks/Java/quarkus/reactive-routes-pgclient/src/main/java/io/quarkus/benchmark/resource/DbResource.java +++ b/frameworks/Java/quarkus/reactive-routes-pgclient/src/main/java/io/quarkus/benchmark/resource/DbResource.java @@ -40,7 +40,7 @@ public void queries(final RoutingContext rc) { }); Uni.combine().all().unis(worlds) - .combinedWith(v -> Arrays.asList(ret)) + .with(v -> Arrays.asList(ret)) .subscribe().with(list -> { sendJson(rc, new JsonArray(list)); }, @@ -61,7 +61,7 @@ public void updates(final RoutingContext rc) { }); Uni.combine().all().unis(worlds) - .combinedWith(v -> null) + .with(v -> null) .flatMap(v -> worldRepository.update(wordsToUpdate)) .map(updated -> wordsToUpdate) .subscribe().with(updatedWordsOrderedById -> { diff --git a/frameworks/Java/quarkus/resteasy-reactive-hibernate-reactive/src/main/java/io/quarkus/benchmark/repository/WorldRepository.java b/frameworks/Java/quarkus/resteasy-reactive-hibernate-reactive/src/main/java/io/quarkus/benchmark/repository/WorldRepository.java index 6aba8d45b00..90130a91022 100644 --- a/frameworks/Java/quarkus/resteasy-reactive-hibernate-reactive/src/main/java/io/quarkus/benchmark/repository/WorldRepository.java +++ b/frameworks/Java/quarkus/resteasy-reactive-hibernate-reactive/src/main/java/io/quarkus/benchmark/repository/WorldRepository.java @@ -31,7 +31,7 @@ public Uni createData() { world.setRandomNumber(random.getNextRandom()); unis[i] = s.persist(world).map(v -> null); } - return Uni.combine().all().unis(unis).combinedWith(l -> null) + return Uni.combine().all().unis(unis).with(l -> null) .flatMap(v -> s.flush()) .map(v -> null); });