fix #323 When received the last HTTP packet but still sending the req…

…uest, force the channel close
reactor · May 1, 2018 · dac97b5 · dac97b5
1 parent ac103c0
commit dac97b5
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/reactor/ipc/netty/http/client/HttpClientOperations.java b/src/main/java/reactor/ipc/netty/http/client/HttpClientOperations.java
@@ -594,6 +594,9 @@ protected void onInboundNext(ChannelHandlerContext ctx, Object msg) {
 			}
 			//force auto read to enable more accurate close selection now inbound is done
 			channel().config().setAutoRead(true);
+			if (markSentBody()) {
+				markPersistent(false);
+			}
 			onHandlerTerminate();
 			return;
 		}