diff --git a/core/src/test/java/com/linecorp/armeria/common/stream/AbstractStreamMessageTest.java b/core/src/test/java/com/linecorp/armeria/common/stream/AbstractStreamMessageTest.java
index <HASH>..<HASH> 100644
--- a/core/src/test/java/com/linecorp/armeria/common/stream/AbstractStreamMessageTest.java
+++ b/core/src/test/java/com/linecorp/armeria/common/stream/AbstractStreamMessageTest.java
@@ -362,7 +362,7 @@ public abstract class AbstractStreamMessageTest {
         }, true);
 
         await().untilAsserted(() -> assertThat(stream.isOpen()).isFalse());
-        assertThat(data.refCnt()).isZero();
+        await().untilAsserted(() -> assertThat(data.refCnt()).isZero());
     }
 
     @Test
@@ -396,7 +396,7 @@ public abstract class AbstractStreamMessageTest {
         }, true);
 
         await().untilAsserted(() -> assertThat(stream.isOpen()).isFalse());
-        assertThat(data.refCnt()).isZero();
+        await().untilAsserted(() -> assertThat(data.refCnt()).isZero());
     }
 
     private void assertSuccess() {
Wait for refcnt assertions. (#<I>)