diff --git a/core/src/test/java/com/linecorp/armeria/server/ServerMetricsTest.java b/core/src/test/java/com/linecorp/armeria/server/ServerMetricsTest.java index 11b21bcac4a..43106ff8cf3 100644 --- a/core/src/test/java/com/linecorp/armeria/server/ServerMetricsTest.java +++ b/core/src/test/java/com/linecorp/armeria/server/ServerMetricsTest.java @@ -206,7 +206,7 @@ void checkWhenOk(SessionProtocol sessionProtocol, long expectedPendingHttp1Reque assertThat(result.status()).isSameAs(HttpStatus.OK); assertThat(serverMetrics.pendingRequests()).isZero(); - assertThat(serverMetrics.activeRequests()).isZero(); + await().untilAsserted(() -> assertThat(serverMetrics.activeRequests()).isZero()); await().until(() -> serverMetrics.activeConnections() == 0); } } @@ -273,7 +273,7 @@ void checkWhenRequestTimeout(SessionProtocol sessionProtocol, long expectedPendi assertThat(result.status()).isSameAs(HttpStatus.SERVICE_UNAVAILABLE); assertThat(serverMetrics.pendingRequests()).isZero(); - assertThat(serverMetrics.activeRequests()).isZero(); + await().untilAsserted(() -> assertThat(serverMetrics.activeRequests()).isZero()); await().until(() -> serverMetrics.activeConnections() == 0); } }