Handler Stream Dispose Fix

Hydra/Http/HttpRequest.cs

@@ -163,7 +163,7 @@ private void Validate()
                     if (distinct.Length != 1 || !int.TryParse(distinct[0], out length)) throw new InvalidContentLengthException();
                 }
 
-                body = new SizedStream(reader.Stream, length);
+                body = new SizedStream(reader.Stream, length, false);
             }
             // if a request has neither Transfer-Encoding nor Content-Length headers it is assumed to have an empty body
             else body = Stream.Null;

Hydra/SizedStream.cs

@@ -20,7 +20,7 @@ internal class SizedStream : WrapperStream
         /// </summary>
         /// <param name="stream">Stream to wrap</param>
         /// <param name="length">Length to limit to</param>
-        internal SizedStream(Stream stream, int length) : base(stream)
+        internal SizedStream(Stream stream, int length, bool ownStream = false) : base(stream, ownStream)
         {
             this.length = length;
         }

Hydra/WebSocket/WebSocket.cs

@@ -302,7 +302,8 @@ private async ValueTask<SemaphoreSlimLock> FullWriterLock(CancellationToken canc
                 currentStream = new WebSocketMaskedStream(
                     new SizedStream(reader.Reader.AsStream(false),
                     (int)frameInfo.Value.Length),
-                    frameInfo.Value.MaskingKey);
+                    frameInfo.Value.MaskingKey,
+                    true);
             }
             else if (frameInfo.Value.Opcode is not WebSocketOpcode.Text and not WebSocketOpcode.Binary) throw new NonFrameableMessageFramedException();
             else currentStream = null; // TODO: Fragmented stream

Hydra/WebSocket/WebSocketMaskedStream.cs

@@ -10,7 +10,7 @@ internal class WebSocketMaskedStream : WrapperStream
     {
         private readonly WebSocketMasker masker;
 
-        internal WebSocketMaskedStream(Stream stream, uint maskingKey) : base(stream)
+        internal WebSocketMaskedStream(Stream stream, uint maskingKey, bool ownStream) : base(stream, ownStream)
         {
             masker = new(maskingKey);
         }

Hydra/WrapperStream.cs

@@ -8,10 +8,12 @@ namespace Hydra
     internal abstract class WrapperStream : ReadOnlyStream
     {
         private readonly Stream stream;
+        private readonly bool ownStream;
 
-        protected WrapperStream(Stream stream)
+        protected WrapperStream(Stream stream, bool ownStream = false)
         {
             this.stream = stream;
+            this.ownStream = ownStream;
         }
 
         public override long Length => stream.Length;
@@ -23,7 +25,7 @@ protected WrapperStream(Stream stream)
 
         protected override void Dispose(bool disposing)
         {
-            if (disposing) stream.Dispose();
+            if (ownStream && disposing) stream.Dispose();
             base.Dispose(disposing);
         }
         public override async ValueTask DisposeAsync()