Commit f38e863f authored by Stephane Nicoll's avatar Stephane Nicoll

Properly subscribe to CloseableConnectionFactory#close

Closes gh-25565
parent c8101f8c
...@@ -59,7 +59,7 @@ class ConnectionPoolMetricsTests { ...@@ -59,7 +59,7 @@ class ConnectionPoolMetricsTests {
@AfterEach @AfterEach
void close() { void close() {
if (this.connectionFactory != null) { if (this.connectionFactory != null) {
this.connectionFactory.close(); StepVerifier.create(this.connectionFactory.close()).verifyComplete();
} }
} }
......
...@@ -59,7 +59,7 @@ class ConnectionFactoryHealthIndicatorTests { ...@@ -59,7 +59,7 @@ class ConnectionFactoryHealthIndicatorTests {
}).verifyComplete(); }).verifyComplete();
} }
finally { finally {
connectionFactory.close(); StepVerifier.create(connectionFactory.close()).verifyComplete();
} }
} }
...@@ -110,7 +110,7 @@ class ConnectionFactoryHealthIndicatorTests { ...@@ -110,7 +110,7 @@ class ConnectionFactoryHealthIndicatorTests {
}).verifyComplete(); }).verifyComplete();
} }
finally { finally {
connectionFactory.close(); StepVerifier.create(connectionFactory.close()).verifyComplete();
} }
} }
...@@ -130,7 +130,7 @@ class ConnectionFactoryHealthIndicatorTests { ...@@ -130,7 +130,7 @@ class ConnectionFactoryHealthIndicatorTests {
}).verifyComplete(); }).verifyComplete();
} }
finally { finally {
connectionFactory.close(); StepVerifier.create(connectionFactory.close()).verifyComplete();
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment