Make sure both sides of the loop close in AdaptedPipeline

Author: davidfowl

src/Kestrel.Core/Adapter/Internal/AdaptedPipeline.cs

@@ -22,7 +22,7 @@ public class AdaptedPipeline : IDuplexPipe, IDisposable
         public AdaptedPipeline(Pipe inputPipe,
                                Pipe outputPipe,
                                ILogger log,
-                               IDuplexPipe transport = null)
+                               IDuplexPipe transport)
         {
             _transport = transport;
             Input = inputPipe;
@@ -65,6 +65,11 @@ private async Task WriteOutputAsync(Stream stream)
 
                     try
                     {
+                        if (result.IsCanceled)
+                        {
+                            break;
+                        }
+
                         if (buffer.IsEmpty)
                         {
                             if (result.IsCompleted)
@@ -113,7 +118,10 @@ private async Task WriteOutputAsync(Stream stream)
             {
                 Output.Reader.Complete();
 
-                _transport?.Output.Complete();
+                _transport.Output.Complete();
+
+                // Cancel any pending flushes due to back-pressure
+                Input.Writer.CancelPendingFlush();
             }
         }
 
@@ -151,7 +159,7 @@ private async Task ReadInputAsync(Stream stream)
 
                     var result = await Input.Writer.FlushAsync();
 
-                    if (result.IsCompleted)
+                    if (result.IsCompleted || result.IsCanceled)
                     {
                         break;
                     }
@@ -168,7 +176,10 @@ private async Task ReadInputAsync(Stream stream)
 
                 // The application could have ended the input pipe so complete
                 // the transport pipe as well
-                _transport?.Input.Complete();
+                _transport.Input.Complete();
+
+                // Cancel any pending reads from the application
+                Output.Reader.CancelPendingRead();
             }
         }