diff --git a/reactor-netty5-http/src/test/java/reactor/netty5/http/server/logging/AccessLogHandlerH1Tests.java b/reactor-netty5-http/src/test/java/reactor/netty5/http/server/logging/AccessLogHandlerH1Tests.java
index cb798a14cf..ae4cc321f4 100644
--- a/reactor-netty5-http/src/test/java/reactor/netty5/http/server/logging/AccessLogHandlerH1Tests.java
+++ b/reactor-netty5-http/src/test/java/reactor/netty5/http/server/logging/AccessLogHandlerH1Tests.java
@@ -59,6 +59,8 @@ void responseNonChunked() {
 		channel.writeOutbound(newHttpResponse(false));
 
 		channel.writeOutbound(new DefaultLastHttpContent(channel.bufferAllocator().allocate(0)));
+
+		assertThat(channel.finishAndReleaseAll()).isTrue();
 	}
 
 	@Test
diff --git a/reactor-netty5-http/src/test/java/reactor/netty5/http/server/logging/AccessLogHandlerH2Tests.java b/reactor-netty5-http/src/test/java/reactor/netty5/http/server/logging/AccessLogHandlerH2Tests.java
index f91867fb62..aa5a393cdc 100644
--- a/reactor-netty5-http/src/test/java/reactor/netty5/http/server/logging/AccessLogHandlerH2Tests.java
+++ b/reactor-netty5-http/src/test/java/reactor/netty5/http/server/logging/AccessLogHandlerH2Tests.java
@@ -61,6 +61,8 @@ void accessLogArgs() {
 		Buffer buffer = channel.bufferAllocator().allocate(RESPONSE_CONTENT.length);
 		buffer.writeBytes(RESPONSE_CONTENT).makeReadOnly();
 		channel.writeOutbound(new DefaultHttp2DataFrame(buffer.send(), true));
+
+		assertThat(channel.finishAndReleaseAll()).isTrue();
 	}
 
 	private void assertAccessLogArgProvider(AccessLogArgProvider args, SocketAddress remoteAddress) {