diff --git a/spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/metrics/r2dbc/ConnectionPoolMetricsTests.java b/spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/metrics/r2dbc/ConnectionPoolMetricsTests.java index e9fd2f0267f..9af5ef76ca6 100644 --- a/spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/metrics/r2dbc/ConnectionPoolMetricsTests.java +++ b/spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/metrics/r2dbc/ConnectionPoolMetricsTests.java @@ -59,7 +59,7 @@ class ConnectionPoolMetricsTests { @AfterEach void close() { if (this.connectionFactory != null) { - this.connectionFactory.close(); + StepVerifier.create(this.connectionFactory.close()).verifyComplete(); } } diff --git a/spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/r2dbc/ConnectionFactoryHealthIndicatorTests.java b/spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/r2dbc/ConnectionFactoryHealthIndicatorTests.java index 1327743f83b..d5a743dd974 100644 --- a/spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/r2dbc/ConnectionFactoryHealthIndicatorTests.java +++ b/spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/r2dbc/ConnectionFactoryHealthIndicatorTests.java @@ -59,7 +59,7 @@ class ConnectionFactoryHealthIndicatorTests { }).verifyComplete(); } finally { - connectionFactory.close(); + StepVerifier.create(connectionFactory.close()).verifyComplete(); } } @@ -110,7 +110,7 @@ class ConnectionFactoryHealthIndicatorTests { }).verifyComplete(); } finally { - connectionFactory.close(); + StepVerifier.create(connectionFactory.close()).verifyComplete(); } } @@ -130,7 +130,7 @@ class ConnectionFactoryHealthIndicatorTests { }).verifyComplete(); } finally { - connectionFactory.close(); + StepVerifier.create(connectionFactory.close()).verifyComplete(); } }