Cancel timeouts asap, close AsyncHttpClient#848

Author: slandelle

providers/netty3/src/main/java/org/asynchttpclient/providers/netty3/future/NettyResponseFuture.java

@@ -199,6 +199,8 @@ private V getContent() throws ExecutionException {
 
     private boolean terminateAndExit() {
         cancelTimeouts();
+        this.channel = null;
+        this.reuseChannel = false;
         return isDone.getAndSet(true) || isCancelled.get();
     }
 
@@ -388,11 +390,6 @@ public void attachChannel(Channel channel, boolean reuseChannel) {
         this.reuseChannel = reuseChannel;
     }
 
-    public void detachChannel() {
-        this.channel = null;
-        this.reuseChannel = false;
-    }
-
     public Channel channel() {
         return channel;
     }

providers/netty3/src/main/java/org/asynchttpclient/providers/netty3/handler/HttpProtocol.java

@@ -189,7 +189,7 @@ private void addType3NTLMAuthorizationHeader(String auth, FluentCaseInsensitiveS
 
     private void finishUpdate(final NettyResponseFuture<?> future, Channel channel, boolean expectOtherChunks) throws IOException {
 
-        future.detachChannel();
+        future.cancelTimeouts();
 
         boolean keepAlive = future.isKeepAlive();
         if (expectOtherChunks && keepAlive)

providers/netty4/src/main/java/org/asynchttpclient/providers/netty4/future/NettyResponseFuture.java

@@ -199,6 +199,8 @@ private V getContent() throws ExecutionException {
 
     private boolean terminateAndExit() {
         cancelTimeouts();
+        this.channel = null;
+        this.reuseChannel = false;
         return isDone.getAndSet(true) || isCancelled.get();
     }
 
@@ -388,11 +390,6 @@ public void attachChannel(Channel channel, boolean reuseChannel) {
         this.reuseChannel = reuseChannel;
     }
 
-    public void detachChannel() {
-        this.channel = null;
-        this.reuseChannel = false;
-    }
-
     public Channel channel() {
         return channel;
     }

providers/netty4/src/main/java/org/asynchttpclient/providers/netty4/handler/HttpProtocol.java

@@ -190,7 +190,7 @@ private void addType3NTLMAuthorizationHeader(String authenticateHeader, FluentCa
 
     private void finishUpdate(final NettyResponseFuture<?> future, Channel channel, boolean expectOtherChunks) throws IOException {
 
-        future.detachChannel();
+        future.cancelTimeouts();
 
         boolean keepAlive = future.isKeepAlive();
         if (expectOtherChunks && keepAlive)