#375 Response stream corruption when a request is cancelled

Author: Ben de Bruyn

src/Docker.DotNet/Endpoints/StreamUtil.cs

@@ -14,12 +14,12 @@ internal static async Task MonitorStreamAsync(Task<Stream> streamTask, DockerCli
             using (var stream = await streamTask)
             {
                 // ReadLineAsync must be cancelled by closing the whole stream.
-                using (cancel.Register(() => stream.Dispose()))
+                //using (cancel.Register(() => stream.Dispose()))
                 {
                     using (var reader = new StreamReader(stream, new UTF8Encoding(false)))
                     {
                         string line;
-                        while ((line = await reader.ReadLineAsync()) != null)
+                        while ((line = await reader.ReadLineAsync()) != null && !cancel.IsCancellationRequested)
                         {
                             progress.Report(line);
                         }
@@ -33,14 +33,14 @@ internal static async Task MonitorStreamForMessagesAsync<T>(Task<Stream> streamT
             using (var stream = await streamTask)
             {
                 // ReadLineAsync must be cancelled by closing the whole stream.
-                using (cancel.Register(() => stream.Dispose()))
+                //using (cancel.Register(() => stream.Dispose()))
                 {
                     using (var reader = new StreamReader(stream, new UTF8Encoding(false)))
                     {
                         string line;
                         try
                         {
-                            while ((line = await reader.ReadLineAsync()) != null)
+                            while ((line = await reader.ReadLineAsync()) != null && !cancel.IsCancellationRequested)
                             {
                                 var prog = client.JsonSerializer.DeserializeObject<T>(line);
                                 if (prog == null) continue;