Completabile Risultati concatenamento provvisorio

Question

Sto tentando di associare le chiamate/risultati dei metodi alla prossima chiamata. Ricevo l'errore di compilazione methodE perché non riesco a ottenere il riferimento di objB dalla chiamata precedente.

Come posso passare il risultato della chiamata precedente alla catena successiva? Ho completamente frainteso il processo?

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

Si potrebbe memorizzare intermedio CompletableFuture in una variabile e quindi utilizzare thenCombine:

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

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

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

objC = futureC.join();