Trying to figure out diff

Author: jkotalik

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

@@ -285,9 +285,9 @@ private async Task InnerProcessRequestsAsync<TContext>(IHttpApplication<TContext
                     stream.Abort(new ConnectionAbortedException("Connection is shutting down."));
                 }
 
-                ControlStream.Abort(new ConnectionAbortedException("Connection is shutting down."));
-                EncoderStream.Abort(new ConnectionAbortedException("Connection is shutting down."));
-                DecoderStream.Abort(new ConnectionAbortedException("Connection is shutting down."));
+                ControlStream?.Abort(new ConnectionAbortedException("Connection is shutting down."));
+                EncoderStream?.Abort(new ConnectionAbortedException("Connection is shutting down."));
+                DecoderStream?.Abort(new ConnectionAbortedException("Connection is shutting down."));
 
                 await controlTask;
                 await encoderTask;

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

@@ -30,6 +30,8 @@ internal abstract class Http3Stream : HttpProtocol, IHttpHeadersHandler, IThread
 
         private readonly Http3Connection _http3Connection;
         private bool _receivedHeaders;
+        private Task _appTask = Task.CompletedTask;
+
         public Pipe RequestBodyPipe { get; }
 
         public Http3Stream(Http3Connection http3Connection, Http3StreamContext context) 
@@ -171,9 +173,11 @@ public async Task ProcessRequestAsync<TContext>(IHttpApplication<TContext> appli
             {
                 var streamError = error as ConnectionAbortedException
                     ?? new ConnectionAbortedException("The stream has completed.", error);
+
+                //await _appTask;
                 try
                 {
-                    _frameWriter.Complete();
+                    //_frameWriter.Complete();
                 }
                 catch
                 {
@@ -232,7 +236,7 @@ private Task ProcessHeadersFrameAsync<TContext>(IHttpApplication<TContext> appli
 
             _receivedHeaders = true;
 
-            Task.Run(() => base.ProcessRequestsAsync(application));
+            _appTask = Task.Run(() => base.ProcessRequestsAsync(application));
             return Task.CompletedTask;
         }
 

src/Servers/Kestrel/samples/Http3SampleApp/Program.cs

@@ -14,7 +14,7 @@ public class Program
     {
         public static void Main(string[] args)
         {
-            var cert = CertificateLoader.LoadFromStoreCert("JUSTIN-LAPTOP", StoreName.My.ToString(), StoreLocation.LocalMachine, true);
+            var cert = CertificateLoader.LoadFromStoreCert("JUSTIN-LAPTOP", StoreName.My.ToString(), StoreLocation.CurrentUser, false);
 
             var hostBuilder = new HostBuilder()
                 .ConfigureLogging((_, factory) =>
@@ -33,7 +33,7 @@ public static void Main(string[] args)
                     })
                     .ConfigureKestrel((context, options) =>
                     {
-                        var basePort = 4444;
+                        var basePort = 5557;
                         options.EnableAltSvc = true;
                         options.Listen(IPAddress.Any, basePort, listenOptions =>
                         {