From cc4680fffcd6744f8216bacf954e2a282d27d1bc Mon Sep 17 00:00:00 2001
From: Violeta Georgieva <violetag@vmware.com>
Date: Thu, 1 Dec 2022 10:17:09 +0200
Subject: [PATCH] [test] Ensure the connection is closed at the end of the test

---
 .../java/reactor/netty/ContextPropagationTest.java          | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

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();