fix #224: Emit error signal when the connection is closed prematurely

reactor · Dec 6, 2017 · 168b2eb · 168b2eb
1 parent b9faa47
commit 168b2eb
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/main/java/reactor/ipc/netty/channel/ChannelOperations.java b/src/main/java/reactor/ipc/netty/channel/ChannelOperations.java
@@ -417,7 +417,10 @@ protected final void onHandlerTerminate() {
 			try {
 				Operators.terminate(OUTBOUND_CLOSE, this);
 				onInactive.onComplete(); //signal senders and other interests
-				inbound.onInboundComplete();
+				// Do not call directly inbound.onInboundComplete()
+				// HttpClientOperations need to notify with error
+				// when there is no response state
+				onInboundComplete();
 			}
 			finally {
 				channel.pipeline()