Notify with original exception

Author: slandelle

client/src/main/java/org/asynchttpclient/netty/NettyResponseFuture.java

@@ -90,6 +90,7 @@ public final class NettyResponseFuture<V> extends AbstractListenableFuture<V> {
     private boolean allowConnect;
     private Realm realm;
     private Realm proxyRealm;
+    public Throwable pendingException;
 
     public NettyResponseFuture(Request originalRequest,//
             AsyncHandler<V> asyncHandler,//
@@ -325,7 +326,7 @@ public int incrementAndGetCurrentRedirectCount() {
     public void setTimeoutsHolder(TimeoutsHolder timeoutsHolder) {
         this.timeoutsHolder = timeoutsHolder;
     }
-    
+
     public TimeoutsHolder getTimeoutsHolder() {
         return timeoutsHolder;
     }

client/src/main/java/org/asynchttpclient/netty/handler/AsyncHttpClientHandler.java

@@ -195,6 +195,7 @@ public void exceptionCaught(ChannelHandlerContext ctx, Throwable e) throws Excep
 
                 if (StackTraceInspector.recoverOnReadOrWriteException(cause)) {
                     logger.debug("Trying to recover from dead Channel: {}", channel);
+                    future.pendingException = cause;
                     return;
                 }
             } else if (attribute instanceof Callback) {

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

@@ -383,10 +383,13 @@ public void abort(Channel channel, NettyResponseFuture<?> future, Throwable t) {
     }
 
     public void handleUnexpectedClosedChannel(Channel channel, NettyResponseFuture<?> future) {
-        if (future.isDone())
+        if (future.isDone()) {
             channelManager.closeChannel(channel);
-        else if (!retry(future))
-            abort(channel, future, RemotelyClosedException.INSTANCE);
+        } else if (retry(future)) {
+            future.pendingException = null;
+        } else {
+            abort(channel, future, future.pendingException != null? future.pendingException : RemotelyClosedException.INSTANCE);
+        }
     }
 
     public boolean retry(NettyResponseFuture<?> future) {