import com.koushikdutta.async.parser.AsyncParser; //导入依赖的package包/类
public <T> SimpleFuture<T> execute(AsyncHttpRequest req, final AsyncParser<T> parser, final RequestCallback<T> callback) {
    final FutureAsyncHttpResponse cancel = new FutureAsyncHttpResponse();
    final SimpleFuture<T> ret = new SimpleFuture<T>();
    execute(req, 0, cancel, new HttpConnectCallback() {
        @Override
        public void onConnectCompleted(Exception ex, final AsyncHttpResponse response) {
            if (ex != null) {
                invoke(callback, ret, response, ex, null);
                return;
            }
            invokeConnect(callback, response);

            Future<T> parsed = parser.parse(response)
            .setCallback(new FutureCallback<T>() {
                @Override
                public void onCompleted(Exception e, T result) {
                    invoke(callback, ret, response, e, result);
                }
            });

            // reparent to the new parser future
            ret.setParent(parsed);
        }
    });
    ret.setParent(cancel);
    return ret;
}
 

import com.koushikdutta.async.parser.AsyncParser; //导入依赖的package包/类
private <T> SimpleFuture<T> execute(AsyncHttpRequest req, final AsyncParser<T> parser, final RequestCallback<T> callback) {
    final FutureAsyncHttpResponse cancel = new FutureAsyncHttpResponse();
    final SimpleFuture<T> ret = new SimpleFuture<T>();
    final Handler handler = req.getHandler();
    execute(req, 0, cancel, new HttpConnectCallback() {
        @Override
        public void onConnectCompleted(Exception ex, final AsyncHttpResponse response) {
            if (ex != null) {
                invoke(handler, callback, ret, response, ex, null);
                return;
            }
            invokeConnect(callback, response);

            final int contentLength = response.getHeaders().getContentLength();

            Future<T> parsed = parser.parse(response)
            .setCallback(new FutureCallback<T>() {
                @Override
                public void onCompleted(Exception e, T result) {
                    invoke(handler, callback, ret, response, e, result);
                }
            });

            // reparent to the new parser future
            ret.setParent(parsed);
        }
    });
    ret.setParent(cancel);
    return ret;
}