diff --git a/reactor-netty-http/src/test/java/reactor/netty/http/server/HttpServerTests.java b/reactor-netty-http/src/test/java/reactor/netty/http/server/HttpServerTests.java index f036e26da2..c7a1c6e538 100644 --- a/reactor-netty-http/src/test/java/reactor/netty/http/server/HttpServerTests.java +++ b/reactor-netty-http/src/test/java/reactor/netty/http/server/HttpServerTests.java @@ -1266,7 +1266,7 @@ void testExpectErrorWhenConnectionClosed() throws Exception { .uri("/") .responseContent()) .expectError(PrematureCloseException.class) - .verify(Duration.ofSeconds(5)); + .verify(Duration.ofSeconds(10)); assertThat(latch.await(30, TimeUnit.SECONDS)).isTrue(); assertThat(error.get()).isInstanceOf(AbortedException.class); diff --git a/reactor-netty-http/src/test/java/reactor/netty/resources/PooledConnectionProviderDefaultMetricsTest.java b/reactor-netty-http/src/test/java/reactor/netty/resources/PooledConnectionProviderDefaultMetricsTest.java index 92502707b5..f505eca198 100644 --- a/reactor-netty-http/src/test/java/reactor/netty/resources/PooledConnectionProviderDefaultMetricsTest.java +++ b/reactor-netty-http/src/test/java/reactor/netty/resources/PooledConnectionProviderDefaultMetricsTest.java @@ -45,6 +45,7 @@ import java.util.function.Function; import static org.assertj.core.api.Assertions.assertThat; +import static org.awaitility.Awaitility.await; import static reactor.netty.Metrics.ACTIVE_CONNECTIONS; import static reactor.netty.Metrics.ACTIVE_STREAMS; import static reactor.netty.Metrics.ERROR; @@ -308,6 +309,11 @@ void testConnectionPoolPendingAcquireSize(long disposeTimeoutMillis) throws Exce assertThat(latch.await(30, TimeUnit.SECONDS)).isTrue(); + await().atMost(1000, TimeUnit.MILLISECONDS) + .with() + .pollInterval(50, TimeUnit.MILLISECONDS) + .untilAsserted(() -> assertGauge(registry, name, NAME, "http2.testConnectionPoolPendingAcquireSize").hasValueEqualTo(0)); + assertGauge(registry, name, NAME, "http2.testConnectionPoolPendingAcquireSize").hasValueEqualTo(0); } finally {