diff --git a/src/main/java/reactor/netty/http/client/HttpClientConnect.java b/src/main/java/reactor/netty/http/client/HttpClientConnect.java
index c75eab1c82..00608377e4 100644
--- a/src/main/java/reactor/netty/http/client/HttpClientConnect.java
+++ b/src/main/java/reactor/netty/http/client/HttpClientConnect.java
@@ -339,7 +339,7 @@ public void onSubscribe(Subscription s) {
 
 			@Override
 			public void onNext(Connection connection) {
-
+				sink.onCancel(connection);
 			}
 
 			@Override