Skip to content

Commit e3652b6

Browse files
authored
[Quarkus] Mutiny combinedWith has been deprecated for removal (#9873)
Follows-up on #9831
1 parent bb2e66a commit e3652b6

File tree

2 files changed

+3
-3
lines changed
  • frameworks/Java/quarkus
    • reactive-routes-pgclient/src/main/java/io/quarkus/benchmark/resource
    • resteasy-reactive-hibernate-reactive/src/main/java/io/quarkus/benchmark/repository

2 files changed

+3
-3
lines changed

frameworks/Java/quarkus/reactive-routes-pgclient/src/main/java/io/quarkus/benchmark/resource/DbResource.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ public void queries(final RoutingContext rc) {
4040
});
4141

4242
Uni.combine().all().unis(worlds)
43-
.combinedWith(v -> Arrays.asList(ret))
43+
.with(v -> Arrays.asList(ret))
4444
.subscribe().with(list -> {
4545
sendJson(rc, new JsonArray(list));
4646
},
@@ -61,7 +61,7 @@ public void updates(final RoutingContext rc) {
6161
});
6262

6363
Uni.combine().all().unis(worlds)
64-
.combinedWith(v -> null)
64+
.with(v -> null)
6565
.flatMap(v -> worldRepository.update(wordsToUpdate))
6666
.map(updated -> wordsToUpdate)
6767
.subscribe().with(updatedWordsOrderedById -> {

frameworks/Java/quarkus/resteasy-reactive-hibernate-reactive/src/main/java/io/quarkus/benchmark/repository/WorldRepository.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ public Uni<Void> createData() {
3131
world.setRandomNumber(random.getNextRandom());
3232
unis[i] = s.persist(world).map(v -> null);
3333
}
34-
return Uni.combine().all().unis(unis).combinedWith(l -> null)
34+
return Uni.combine().all().unis(unis).with(l -> null)
3535
.flatMap(v -> s.flush())
3636
.map(v -> null);
3737
});

0 commit comments

Comments
 (0)