* Catch System.Threading.Channels.ChannelClosedException when aborting

Author: lukebakken

projects/RabbitMQ.Client/client/impl/Connection.cs

@@ -35,6 +35,7 @@
 using System.IO;
 using System.Runtime.CompilerServices;
 using System.Threading;
+using System.Threading.Channels;
 using System.Threading.Tasks;
 using RabbitMQ.Client.Events;
 using RabbitMQ.Client.Exceptions;
@@ -335,6 +336,13 @@ await _session0.TransmitAsync(method, cancellationToken)
                             .ConfigureAwait(false);
                     }
                 }
+                catch (ChannelClosedException)
+                {
+                    if (false == abort)
+                    {
+                        throw;
+                    }
+                }
                 catch (AlreadyClosedException)
                 {
                     if (false == abort)

projects/Test/Integration/TestConnectionShutdown.cs

@@ -113,7 +113,6 @@ public async Task TestDisposedWithSocketClosedOutOfBand()
                 _conn = null;
                 _channel = null;
             }
-
         }
 
         [Fact]