@Override
    public void onMessageAck(ProcessResult result) {
        this.result = result;
        latch.countDown();
        if (isAsyncCall) {
            callback.onMessageAck(result);
        }
    }
TCP Call Future class

a future implementation for tcp RPCs.
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp/TcpCallFuture.java