PR feedback

Author: JamesNK

src/Servers/Kestrel/Core/src/Internal/Http/Http1MessageBody.cs

@@ -16,9 +16,8 @@ internal abstract class Http1MessageBody : MessageBody
         protected readonly Http1Connection _context;
         protected bool _completed;
 
-        protected Http1MessageBody(Http1Connection context)
+        protected Http1MessageBody(Http1Connection context) : base(context)
         {
-            Reset(context);
             _context = context;
         }
 

src/Servers/Kestrel/Core/src/Internal/Http/MessageBody.cs

@@ -15,7 +15,7 @@ internal abstract class MessageBody
         private static readonly MessageBody _zeroContentLengthClose = new ZeroContentLengthMessageBody(keepAlive: false);
         private static readonly MessageBody _zeroContentLengthKeepAlive = new ZeroContentLengthMessageBody(keepAlive: true);
 
-        private HttpProtocol _context;
+        private readonly HttpProtocol _context;
 
         private bool _send100Continue = true;
         private long _consumedBytes;
@@ -26,6 +26,11 @@ internal abstract class MessageBody
         protected long _alreadyTimedBytes;
         protected long _examinedUnconsumedBytes;
 
+        protected MessageBody(HttpProtocol context)
+        {
+            _context = context;
+        }
+
         public static MessageBody ZeroContentLengthClose => _zeroContentLengthClose;
 
         public static MessageBody ZeroContentLengthKeepAlive => _zeroContentLengthKeepAlive;
@@ -68,9 +73,8 @@ public virtual Task StopAsync()
 
         protected virtual Task OnStopAsync() => Task.CompletedTask;
 
-        protected void Reset(HttpProtocol context)
+        protected void Reset()
         {
-            _context = context;
             _send100Continue = true;
             _consumedBytes = 0;
             _stopped = false;

src/Servers/Kestrel/Core/src/Internal/Http/ZeroContentLengthMessageBody.cs

@@ -11,8 +11,8 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Core.Internal.Http
     internal sealed class ZeroContentLengthMessageBody : MessageBody
     {
         public ZeroContentLengthMessageBody(bool keepAlive)
+            : base(null)
         {
-            Reset(null);
             RequestKeepAlive = keepAlive;
         }
 

src/Servers/Kestrel/Core/src/Internal/Http2/Http2MessageBody.cs

@@ -12,12 +12,12 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Core.Internal.Http2
 {
     internal sealed class Http2MessageBody : MessageBody
     {
-        private Http2Stream _context;
+        private readonly Http2Stream _context;
         private ReadResult _readResult;
 
-        public Http2MessageBody(Http2Stream context)
+        public Http2MessageBody(Http2Stream context) : base(context)
         {
-            Reset(context);
+            _context = context;
         }
 
         protected override void OnReadStarting()
@@ -45,26 +45,9 @@ protected override void OnDataRead(long bytesRead)
             AddAndCheckConsumedBytes(bytesRead);
         }
 
-        public static MessageBody For(Http2Stream context, Http2MessageBody previousMessageBody)
+        public new void Reset()
         {
-            if (context.ReceivedEmptyRequestBody)
-            {
-                return ZeroContentLengthClose;
-            }
-
-            if (previousMessageBody is Http2MessageBody http2MessageBody)
-            {
-                http2MessageBody.Reset(context);
-                return http2MessageBody;
-            }
-
-            return new Http2MessageBody(context);
-        }
-
-        public void Reset(Http2Stream context)
-        {
-            base.Reset(context);
-            _context = context;
+            base.Reset();
             _readResult = default;
         }
 

src/Servers/Kestrel/Core/src/Internal/Http2/Http2Stream.cs

@@ -179,7 +179,7 @@ protected override MessageBody CreateMessageBody()
 
             if (_messageBody != null)
             {
-                _messageBody.Reset(this);
+                _messageBody.Reset();
             }
             else
             {

src/Servers/Kestrel/Core/src/Internal/Http3/Http3MessageBody.cs

@@ -15,9 +15,8 @@ internal sealed class Http3MessageBody : MessageBody
         private readonly Http3Stream _context;
         private ReadResult _readResult;
 
-        private Http3MessageBody(Http3Stream context)
+        private Http3MessageBody(Http3Stream context) : base(context)
         {
-            Reset(context);
             _context = context;
         }
         protected override void OnReadStarting()