Changed future.channel() to channel which is guarded to be non null

Author: Rachid Ben Moussa

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

@@ -464,7 +464,7 @@ private void scheduleReadTimeout(NettyResponseFuture<?> nettyResponseFuture) {
   public void abort(Channel channel, NettyResponseFuture<?> future, Throwable t) {
 
     if (channel != null) {
-      Object attribute = Channels.getAttribute(future.channel());
+      Object attribute = Channels.getAttribute(channel);
       if (attribute instanceof StreamedResponsePublisher) {
         ((StreamedResponsePublisher) attribute).setError(t);
       }

client/src/test/java/org/asynchttpclient/netty/NettyConnectionResetByPeerTest.java

@@ -44,9 +44,7 @@ public void testAsyncHttpClientConnectionResetByPeer() throws InterruptedExcepti
             ).get();
         } catch (ExecutionException e) {
             Throwable ex = e.getCause();
-            assertThat(ex, is(not(instanceOf(TimeoutException.class))));
             assertThat(ex, is(instanceOf(IOException.class)));
-//            assertTrue(ex.getMessage().equalsIgnoreCase("Connection reset by peer"));
         }
     }