CompletableFuture連鎖結果

Question

メソッドの呼び出し/結果を次の呼び出しに連鎖しようとしています。以前の呼び出しからobjBの参照を取得できない場合は、コンパイル時エラーメソッドが返されます。

前の呼び出しの結果を次のチェーンに渡すにはどうすればよいですか？私はプロセスを完全に誤解したことがありますか？

Object objC = CompletableFuture.supplyAsync(() -> service.methodA(obj, width, height)) 
    .thenApply(objA -> { 
    try { 
     return service.methodB(objA); 
    } catch (Exception e) { 
     throw new CompletionException(e); 
    } 
}) 
    .thenApply(objA -> service.methodC(objA)) 
    .thenApply(objA -> { 
    try { 
     return service.methodD(objA); // this returns new objB how do I get it and pass to next chaining call 
     } catch (Exception e) { 
      throw new CompletionException(e); 
     } 
    }) 
    .thenApply((objA, objB) -> { 
     return service.methodE(objA, objB); // compilation error 
    }) 
.get(); 

Answer 1

あなたは変数に中間CompletableFutureを格納し、thenCombineを使用することができます。

CompletableFuture<ClassA> futureA = CompletableFuture.supplyAsync(...) 
    .thenApply(...) 
    .thenApply(...); 

CompletableFuture<ClassB> futureB = futureA.thenApply(...); 

CompletableFuture<ClassC> futureC = futureA.thenCombine(futureB, service::methodE); 

objC = futureC.join();