Fix formatting.

Author: arturobernalg

httpclient5/src/main/java/org/apache/hc/client5/http/impl/async/AsyncConnectExec.java

@@ -191,6 +191,7 @@ public void failed(final Exception ex) {
                         public void cancelled() {
                             asyncExecCallback.failed(new InterruptedIOException());
                         }
+
                     }));
         } else {
             if (execRuntime.isEndpointConnected()) {
@@ -199,6 +200,7 @@ public void cancelled() {
                 proceedToNextHop(state, request, entityProducer, scope, chain, asyncExecCallback);
             }
         }
+
     }
 
     private void proceedToNextHop(
@@ -235,6 +237,7 @@ private void doProceedToNextHop(
         switch (step) {
             case HttpRouteDirector.CONNECT_TARGET:
                 operation.setDependency(execRuntime.connectEndpoint(clientContext, new FutureCallback<AsyncExecRuntime>() {
+
                     @Override
                     public void completed(final AsyncExecRuntime execRuntime) {
                         tracker.connectTarget(route.isSecure());
@@ -253,11 +256,13 @@ public void failed(final Exception ex) {
                     public void cancelled() {
                         asyncExecCallback.failed(new InterruptedIOException());
                     }
+
                 }));
                 break;
 
             case HttpRouteDirector.CONNECT_PROXY:
                 operation.setDependency(execRuntime.connectEndpoint(clientContext, new FutureCallback<AsyncExecRuntime>() {
+
                     @Override
                     public void completed(final AsyncExecRuntime execRuntime) {
                         final HttpHost proxy = route.getProxyHost();
@@ -277,6 +282,7 @@ public void failed(final Exception ex) {
                     public void cancelled() {
                         asyncExecCallback.failed(new InterruptedIOException());
                     }
+
                 }));
                 break;
 
@@ -290,11 +296,16 @@ public void cancelled() {
                 break;
 
             case HttpRouteDirector.TUNNEL_PROXY:
+                // The most simple example for this case is a proxy chain
+                // of two proxies, where P1 must be tunnelled to P2.
+                // route: Source -> P1 -> P2 -> Target (3 hops)
+                // fact:  Source -> P1 -> Target       (2 hops)
                 asyncExecCallback.failed(new HttpException("Proxy chains are not supported"));
                 break;
 
             case HttpRouteDirector.LAYER_PROTOCOL:
                 execRuntime.upgradeTls(clientContext, new FutureCallback<AsyncExecRuntime>() {
+
                     @Override
                     public void completed(final AsyncExecRuntime asyncExecRuntime) {
                         if (LOG.isDebugEnabled()) {
@@ -313,6 +324,7 @@ public void failed(final Exception ex) {
                     public void cancelled() {
                         asyncExecCallback.failed(new InterruptedIOException());
                     }
+
                 });
                 break;
 
@@ -337,7 +349,7 @@ private void createTunnel(
             final State state,
             final HttpHost proxy,
             final HttpHost nextHop,
-            final HttpRoute route,                                   // NEW
+            final HttpRoute route,
             final AsyncExecChain.Scope scope,
             final AsyncExecCallback asyncExecCallback) {
 
@@ -381,7 +393,7 @@ public void cancel() {
             @Override
             public void produceRequest(final RequestChannel requestChannel,
                                        final HttpContext httpContext) throws HttpException, IOException {
-                final BasicHttpRequest connect = new BasicHttpRequest(Method.CONNECT, nextHop, nextHop.toHostString());
+                final HttpRequest connect = new BasicHttpRequest(Method.CONNECT, nextHop, nextHop.toHostString());
                 connect.setVersion(HttpVersion.HTTP_1_1);
 
                 // --- RFC 7639: inject ALPN header (if provided) ----------------
@@ -408,7 +420,8 @@ public int available() {
             }
 
             @Override
-            public void consumeInformation(final HttpResponse r, final HttpContext c) throws HttpException, IOException {
+            public void consumeInformation(final HttpResponse httpResponse,
+                                           final HttpContext httpContext) throws HttpException, IOException {
             }
 
             @Override
@@ -476,6 +489,7 @@ public void streamEnd(final List<? extends Header> trailers) throws HttpExceptio
         } else {
             operation.setDependency(execRuntime.execute(exchangeId, internalExchangeHandler, clientContext));
         }
+
     }
 
     private boolean needAuthentication(
@@ -528,4 +542,5 @@ private void proceedConnected(
             asyncExecCallback.failed(ex);
         }
     }
+
 }