Ensure the messages are closed after the test execution

reactor · Sep 21, 2022 · 3b51a75 · 3b51a75
1 parent 4b6be49
commit 3b51a75
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...netty5-http/src/test/java/reactor/netty5/http/server/logging/AccessLogHandlerH1Tests.java b/...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/...netty5-http/src/test/java/reactor/netty5/http/server/logging/AccessLogHandlerH2Tests.java b/...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) {