Perform WriteListener#abortOnThrowable whatever the channel state, close AsyncHttpClient#1488

Motivation

For some reason lost in time, abortOnThrowable is only performed if the
channel is not a new one.
I have no idea why and it swallow exceptions, so we get timeouts
instead of actual exception.

Modification:

Drop this test and always perform abortOnThrowable, whatever the
channel state.

Result:

Proper exception reported

Author: slandelle

client/src/main/java/org/asynchttpclient/netty/request/WriteListener.java

@@ -19,7 +19,6 @@
 
 import org.asynchttpclient.handler.ProgressAsyncHandler;
 import org.asynchttpclient.netty.NettyResponseFuture;
-import org.asynchttpclient.netty.channel.ChannelState;
 import org.asynchttpclient.netty.channel.Channels;
 import org.asynchttpclient.netty.future.StackTraceInspector;
 import org.slf4j.Logger;
@@ -39,7 +38,7 @@ public WriteListener(NettyResponseFuture<?> future, boolean notifyHeaders) {
     }
 
     private boolean abortOnThrowable(Channel channel, Throwable cause) {
-        if (cause != null && future.getChannelState() != ChannelState.NEW) {
+        if (cause != null) {
             if (cause instanceof IllegalStateException || cause instanceof ClosedChannelException || StackTraceInspector.recoverOnReadOrWriteException(cause)) {
                 LOGGER.debug(cause.getMessage(), cause);
                 Channels.silentlyCloseChannel(channel);

client/src/test/java/org/asynchttpclient/request/body/PutFileTest.java

@@ -35,8 +35,7 @@ public class PutFileTest extends AbstractBasicTest {
 
     private void put(int fileSize) throws Exception {
         File file = createTempFile(fileSize);
-        int timeout = (int) file.length() / 1000;
-        try (AsyncHttpClient client = asyncHttpClient(config().setRequestTimeout(timeout))) {
+        try (AsyncHttpClient client = asyncHttpClient(config().setRequestTimeout(2000))) {
             Response response = client.preparePut(getTargetUrl()).setBody(file).execute().get();
             assertEquals(response.getStatusCode(), 200);
         }