這一組方法接受一個Function作為參數，這個Function的輸入是當前的CompletableFuture的計算值，返回結果將是一個新的CompletableFuture，這個新的CompletableFuture會組合原來的CompletableFuture和函數返回的CompletableFuture。

現在就能看出CompletableFuture的強大了，它解決了自定義ResponseFuture的許多問題，該類有幾十個方法，感興趣的可以去一一嘗試。

可以看到以前的版本只能在RpcContext中進行獲取。而經過改良后，首先RpcContext一樣能過獲取，其次在過濾器鏈返回的Result中也能獲取，可以從最新的代碼中看到，原先的RpcResult類已經被去除，而在AsyncRpcResult也繼承了CompletableFuture類，也就是說有AsyncRpcResult的地方，就有CompletableFuture。并且在后續的dubbo3.0中，AsyncRpcResult將會內置CompletableFuture類型的變量，CompletableFuture的獲取方式也會大大增加。

接下來我就來講解一下AsyncRpcResult類。

/**
 * 當相同的線程用于執行另一個RPC調用時，并且回調發生時，原來的RpcContext可能已經被更改。
 * 所以我們應該保留當前RpcContext實例的引用，并在執行回調之前恢復它。
 * 存儲當前的RpcContext
 */
private RpcContext storedContext;
/**
 * 存儲當前的ServerContext
 */
private RpcContext storedServerContext;

/**
 * 會話域
 */
private Invocation invocation;

public AsyncRpcResult(Invocation invocation) {
    // 設置會話域
    this.invocation = invocation;
    // 獲得當前線程內代表消費者端的Context
    this.storedContext = RpcContext.getContext();
    // 獲得當前線程內代表服務端的Context
    this.storedServerContext = RpcContext.getServerContext();
}

/**
 * 轉換成新的AsyncRpcResult
 * @param asyncRpcResult
 */
public AsyncRpcResult(AsyncRpcResult asyncRpcResult) {
    this.invocation = asyncRpcResult.getInvocation();
    this.storedContext = asyncRpcResult.getStoredContext();
    this.storedServerContext = asyncRpcResult.getStoredServerContext();
}

上面的是AsyncRpcResult核心的變量以及構造函數，storedContext和storedServerContext存儲了相關的RpcContext實例的引用，為的就是防止在回調的時候由于相同的線程用于執行另一個RPC調用導致原來的RpcContext可能已經被更改。所以存儲下來后，我們需要在執行回調之前恢復它。具體的可以看下面的thenApplyWithContext方法。

@Override
public Object getValue() {
    // 獲得計算的結果
    return getAppResponse().getValue();
}

@Override
public void setValue(Object value) {
    // 創建一個AppResponse實例
    AppResponse appResponse = new AppResponse();
    // 把結果放入AppResponse
    appResponse.setValue(value);
    // 標志該future完成，并且把攜帶結果的appResponse設置為該future的結果
    this.complete(appResponse);
}

@Override
public Throwable getException() {
    // 獲得拋出的異常信息
    return getAppResponse().getException();
}

@Override
public void setException(Throwable t) {
    // 創建一個AppResponse實例
    AppResponse appResponse = new AppResponse();
    // 把異常放入appResponse
    appResponse.setException(t);
    // 標志該future完成，并且把攜帶異常的appResponse設置為該future的結果
    this.complete(appResponse);
}

@Override
public boolean hasException() {
    // 設置是否有拋出異常
    return getAppResponse().hasException();
}

public Result getAppResponse() {
    // 如果該結果計算完成，則直接調用get方法獲得結果
    try {
        if (this.isDone()) {
            return this.get();
        }
    } catch (Exception e) {
        // This should never happen;
        logger.error("Got exception when trying to fetch the underlying result from AsyncRpcResult.", e);
    }
    // 創建AppResponse
    return new AppResponse();
}

這些實現了Result接口的方法，可以發現其中都是調用了AppResponse的方法，AppResponse跟AsyncRpcResult一樣也繼承了AbstractResult，不過它是作為回調的數據結構。AppResponse我會在異步化過濾器鏈回調中講述。

@Override
public Object recreate() throws Throwable {
    // 強制類型轉化
    RpcInvocation rpcInvocation = (RpcInvocation) invocation;
    // 如果返回的是future類型
    if (InvokeMode.FUTURE == rpcInvocation.getInvokeMode()) {
        // 創建AppResponse實例
        AppResponse appResponse = new AppResponse();
        // 創建future
        CompletableFuture