CompletableFutureQueue
Chain async transformations on top of CompletableFuture.
CompletableFutureQueue
.define((String s) -> s.length())
.thenCombineAsync(len -> len * 2)
.apply("hello") // CompletableFuture<Integer>
.thenAccept(System.out::println); // 10
Each step runs on the common ForkJoinPool unless you pass an explicit Executor.