From 3b51a7531fcfdb83bc955e7783c2af69fe8a3a62 Mon Sep 17 00:00:00 2001
From: Violeta Georgieva <violetag@vmware.com>
Date: Wed, 21 Sep 2022 11:29:01 +0300
Subject: [PATCH] Ensure the messages are closed after the test execution

---
 .../netty5/http/server/logging/AccessLogHandlerH1Tests.java     | 2 ++
 .../netty5/http/server/logging/AccessLogHandlerH2Tests.java     | 2 ++
 2 files changed, 4 insertions(+)

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) {