diff --git a/server/netty-server/zio/src/main/scala/sttp/tapir/server/netty/zio/internal/ZioStreamCompatible.scala b/server/netty-server/zio/src/main/scala/sttp/tapir/server/netty/zio/internal/ZioStreamCompatible.scala index 7ec3ae4fa9..60a5a2b067 100644 --- a/server/netty-server/zio/src/main/scala/sttp/tapir/server/netty/zio/internal/ZioStreamCompatible.scala +++ b/server/netty-server/zio/src/main/scala/sttp/tapir/server/netty/zio/internal/ZioStreamCompatible.scala @@ -50,7 +50,11 @@ private[zio] object ZioStreamCompatible { val stream = Adapters .publisherToStream(publisher, bufferSize = 2) - .map(httpContent => Chunk.fromByteBuffer(httpContent.content.nioBuffer())) + .map { httpContent => + val bytes = Chunk.fromByteBuffer(httpContent.content.nioBuffer()) + httpContent.release() + bytes + } .flattenChunks maxBytes.map(ZioStreams.limitBytes(stream, _)).getOrElse(stream) }