diff --git a/reactor-netty-core/src/contextPropagationTest/java/reactor/netty/ContextPropagationTest.java b/reactor-netty-core/src/contextPropagationTest/java/reactor/netty/ContextPropagationTest.java
index 1c901e63dd..b1a7f51e58 100644
--- a/reactor-netty-core/src/contextPropagationTest/java/reactor/netty/ContextPropagationTest.java
+++ b/reactor-netty-core/src/contextPropagationTest/java/reactor/netty/ContextPropagationTest.java
@@ -60,11 +60,12 @@ void testContextPropagation(TcpClient client) {
 				         .bindNow();
 
 		ContextRegistry registry = ContextRegistry.getInstance();
+		Connection connection = null;
 		try {
 			registry.registerThreadLocalAccessor(new TestThreadLocalAccessor());
 			TestThreadLocalHolder.value("First");
 
-			Connection connection =
+			connection =
 					client.port(disposableServer.port())
 					      .wiretap(true)
 					      .connect()
@@ -89,6 +90,9 @@ void testContextPropagation(TcpClient client) {
 			          .verify(Duration.ofSeconds(5));
 		}
 		finally {
+			if (connection != null) {
+				connection.disposeNow();
+			}
 			TestThreadLocalHolder.reset();
 			registry.removeThreadLocalAccessor(TestThreadLocalAccessor.KEY);
 			disposableServer.disposeNow();