CompletableKết quả chuỗi kết quả

Question

Tôi đang cố gắng kết nối các cuộc gọi/kết quả của các phương thức với cuộc gọi tiếp theo. Tôi nhận được phương pháp biên dịch lỗi thời gianE bởi vì nếu không thể nhận được tham chiếu của objB từ cuộc gọi trước đó.

Làm cách nào để chuyển kết quả của cuộc gọi trước đó đến chuỗi tiếp theo? Tôi đã hoàn toàn hiểu lầm quá trình chưa?

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

Bạn có thể lưu trữ trung gian CompletableFuture trong một biến và sau đó sử dụng thenCombine:

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

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

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

objC = futureC.join();