Polishing

This commit is contained in:
Juergen Hoeller 2016-10-31 12:45:41 +01:00
parent 7f280a3b17
commit c4ee876416
1 changed files with 6 additions and 7 deletions

View File

@ -100,13 +100,13 @@ final class HttpComponentsAsyncClientHttpRequest extends AbstractBufferingAsyncC
private static class HttpResponseFutureCallback implements FutureCallback<HttpResponse> {
private final HttpUriRequest httpRequest;
private final HttpUriRequest request;
private final ListenableFutureCallbackRegistry<ClientHttpResponse> callbacks =
new ListenableFutureCallbackRegistry<>();
public HttpResponseFutureCallback(HttpUriRequest httpRequest) {
this.httpRequest = httpRequest;
public HttpResponseFutureCallback(HttpUriRequest request) {
this.request = request;
}
public void addCallback(ListenableFutureCallback<? super ClientHttpResponse> callback) {
@ -133,7 +133,7 @@ final class HttpComponentsAsyncClientHttpRequest extends AbstractBufferingAsyncC
@Override
public void cancelled() {
this.httpRequest.abort();
this.request.abort();
}
}
@ -143,8 +143,8 @@ final class HttpComponentsAsyncClientHttpRequest extends AbstractBufferingAsyncC
private final HttpResponseFutureCallback callback;
public ClientHttpResponseFuture(Future<HttpResponse> futureResponse, HttpResponseFutureCallback callback) {
super(futureResponse);
public ClientHttpResponseFuture(Future<HttpResponse> response, HttpResponseFutureCallback callback) {
super(response);
this.callback = callback;
}
@ -165,5 +165,4 @@ final class HttpComponentsAsyncClientHttpRequest extends AbstractBufferingAsyncC
}
}
}