From b5c29e05c06ebc1e34859c6e36b9f288658dcd21 Mon Sep 17 00:00:00 2001 From: uazw Date: Fri, 1 Apr 2022 15:58:20 +0800 Subject: [PATCH] using thenCombine instead of join to merge to CompletableFuture (#31304) --- akka-docs/src/test/java/jdocs/actor/ActorDocTest.java | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/akka-docs/src/test/java/jdocs/actor/ActorDocTest.java b/akka-docs/src/test/java/jdocs/actor/ActorDocTest.java index 53a9efb347..c75112c0fd 100644 --- a/akka-docs/src/test/java/jdocs/actor/ActorDocTest.java +++ b/akka-docs/src/test/java/jdocs/actor/ActorDocTest.java @@ -841,14 +841,7 @@ public class ActorDocTest extends AbstractJavaTest { // using timeout from above CompletableFuture future2 = ask(actorB, "another request", t).toCompletableFuture(); - CompletableFuture transformed = - CompletableFuture.allOf(future1, future2) - .thenApply( - v -> { - String x = (String) future1.join(); - String s = (String) future2.join(); - return new Result(x, s); - }); + CompletableFuture transformed = future1.thenCombine(future2, (x, s) -> new Result((String) x, (String) s)); pipe(transformed, system.dispatcher()).to(actorC); // #ask-pipe