Override MessageToMessageEncoder.encode method, which will close the …

…message for us
reactor · Sep 16, 2022 · 5bb8999 · 5bb8999
1 parent 618e866
commit 5bb8999
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/reactor-netty5-core/src/test/java/reactor/netty5/NettyOutboundTest.java b/reactor-netty5-core/src/test/java/reactor/netty5/NettyOutboundTest.java
@@ -159,11 +159,10 @@ void sendFileWithTlsUsesChunkedFile() throws URISyntaxException, SSLException {
 				//capture the chunks unencrypted, transform as Strings:
 				new MessageToMessageEncoder<Buffer>() {
 					@Override
-					protected void encodeAndClose(ChannelHandlerContext ctx, Buffer msg,
+					protected void encode(ChannelHandlerContext ctx, Buffer msg,
 							List<Object> out) {
 						clearMessages.add(msg.readCharSequence(msg.readableBytes(), StandardCharsets.UTF_8));
 						out.add(msg.split());
-						msg.close();
 					}
 				},
 				//transform the ChunkedFile into Buffer chunks:
@@ -253,10 +252,9 @@ void sendFileWithForceChunkedFileUsesStrategyChunks()
 				//transform the Buffer chunks into Strings:
 				new MessageToMessageEncoder<Buffer>() {
 					@Override
-					protected void encodeAndClose(ChannelHandlerContext ctx, Buffer msg,
+					protected void encode(ChannelHandlerContext ctx, Buffer msg,
 							List<Object> out) {
 						out.add(msg.readCharSequence(msg.readableBytes(), StandardCharsets.UTF_8));
-						msg.close();
 					}
 				},
 				//transform the ChunkedFile into Buffer chunks: