diff --git a/reactor-netty5-core/src/test/java/reactor/netty5/NettyOutboundTest.java b/reactor-netty5-core/src/test/java/reactor/netty5/NettyOutboundTest.java index 1a7ed7802e..34dfab496f 100644 --- a/reactor-netty5-core/src/test/java/reactor/netty5/NettyOutboundTest.java +++ b/reactor-netty5-core/src/test/java/reactor/netty5/NettyOutboundTest.java @@ -163,6 +163,7 @@ protected void encodeAndClose(ChannelHandlerContext ctx, Buffer msg, List out) { clearMessages.add(msg.readCharSequence(msg.readableBytes(), StandardCharsets.UTF_8)); out.add(msg.split()); + msg.close(); } }, //transform the ChunkedFile into Buffer chunks: @@ -255,6 +256,7 @@ void sendFileWithForceChunkedFileUsesStrategyChunks() protected void encodeAndClose(ChannelHandlerContext ctx, Buffer msg, List out) { out.add(msg.readCharSequence(msg.readableBytes(), StandardCharsets.UTF_8)); + msg.close(); } }, //transform the ChunkedFile into Buffer chunks: @@ -338,4 +340,4 @@ static Mono mockSendUsing(Connection c, Callable sourceIn sourceCleanup ); } -} \ No newline at end of file +}