On inbound cancelled event do not close the connection if the inbound…

…'s been disposed
reactor · Feb 1, 2018 · d8e9ca1 · d8e9ca1
1 parent d612d0a
commit d8e9ca1
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
@@ -253,6 +253,9 @@ public HttpClientRequest failOnServerError(boolean shouldFail) {
 
 	@Override
 	protected void onInboundCancel() {
+		if (isInboundDisposed()){
+			return;
+		}
 		channel().close();
 	}