Fixed leak reproduced by HttpServerTests.testIssue1978H2WithDelay.

The Http2StreamBridgeServerHandler.channelRead method was still using old ReferenceCountUtil.release() instead of Resource.dispose() method.
reactor · Sep 21, 2022 · 9e29d50 · 9e29d50
1 parent 3b51a75
commit 9e29d50
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...-netty5-http/src/main/java/reactor/netty5/http/server/Http2StreamBridgeServerHandler.java b/...-netty5-http/src/main/java/reactor/netty5/http/server/Http2StreamBridgeServerHandler.java
@@ -29,7 +29,7 @@
 import io.netty5.handler.codec.http.LastHttpContent;
 import io.netty5.handler.codec.http2.Http2StreamFrameToHttpObjectCodec;
 import io.netty5.handler.ssl.SslHandler;
-import io.netty5.util.ReferenceCountUtil;
+import io.netty5.util.Resource;
 import io.netty5.util.concurrent.Future;
 import io.netty5.util.concurrent.FutureContextListener;
 import reactor.core.publisher.Mono;
@@ -125,7 +125,7 @@ else if (!pendingResponse) {
 				HttpServerOperations.log.debug(format(ctx.channel(), "Dropped HTTP content, " +
 						"since response has been sent already: {}"), msg);
 			}
-			ReferenceCountUtil.release(msg);
+			Resource.dispose(msg);
 			ctx.read();
 			return;
 		}