Merge pull request #342 from NiteshKant/0.x

Errors in the pipeline post response header delivery were lost.
ReactiveX · Mar 24, 2015 · 27a8ec3 · 27a8ec3
2 parents 3b75a70 + fa34f9c
commit 27a8ec3
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...src/main/java/io/reactivex/netty/protocol/http/client/ClientRequestResponseConverter.java b/...src/main/java/io/reactivex/netty/protocol/http/client/ClientRequestResponseConverter.java
@@ -236,6 +236,12 @@ public void channelInactive(ChannelHandlerContext ctx) throws Exception {
         super.channelInactive(ctx);
     }
 
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+        responseState.sendOnError(cause);
+        super.exceptionCaught(ctx, cause);
+    }
+
     @SuppressWarnings("unchecked")
     private static void invokeContentOnNext(Object nextObject, ResponseState stateToUse) {
         try {