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