diff --git a/reactor-netty5-http/src/main/java/reactor/netty5/http/server/Http2StreamBridgeServerHandler.java b/reactor-netty5-http/src/main/java/reactor/netty5/http/server/Http2StreamBridgeServerHandler.java index 93a9eb1b2..60efb6dd3 100644 --- a/reactor-netty5-http/src/main/java/reactor/netty5/http/server/Http2StreamBridgeServerHandler.java +++ b/reactor-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; }