ensure CloseAsync is called

Author: lukebakken

projects/Test/Integration/TestAsyncConsumer.cs

@@ -485,6 +485,7 @@ await _channel.BasicConsumeAsync(queue: queueName, autoAck: false,
                         await publishChannel.WaitForConfirmsOrDieAsync();
                     }
 
+                    await publishChannel.CloseAsync();
                     return true;
                 }
             });
@@ -610,6 +611,7 @@ public async Task TestDeclarationOfManyAutoDeleteQueuesWithTransientConsumer()
                         var dummy = new AsyncEventingBasicConsumer(ch);
                         ConsumerTag tag = await ch.BasicConsumeAsync(q, true, dummy);
                         await ch.BasicCancelAsync(tag);
+                        await ch.CloseAsync();
                     }
                 }));
             }

projects/Test/Integration/TestExchangeDeclare.cs

@@ -76,6 +76,10 @@ await ch.ExchangeBindAsync(destination: ex_destination, source: exchangeName,
                         {
                             nse = e;
                         }
+                        finally
+                        {
+                            await ch.CloseAsync();
+                        }
                     }
                 }
                 var t = Task.Run(f);
@@ -103,6 +107,10 @@ await _channel.ExchangeUnbindAsync(destination: ex_destination, source: exchange
                         {
                             nse = e;
                         }
+                        finally
+                        {
+                            await ch.CloseAsync();
+                        }
                     }
                 }
                 var t = Task.Run(f);
@@ -139,6 +147,10 @@ public async Task TestConcurrentExchangeDeclareAndDelete()
                                 {
                                     nse = e;
                                 }
+                                finally
+                                {
+                                    await ch.CloseAsync();
+                                }
                             }
                         });
                 tasks.Add(t);
@@ -167,6 +179,10 @@ public async Task TestConcurrentExchangeDeclareAndDelete()
                                 {
                                     nse = e;
                                 }
+                                finally
+                                {
+                                    await ch.CloseAsync();
+                                }
                             }
                         });
                 tasks.Add(t);

projects/Test/Integration/TestQueueDeclare.cs

@@ -118,6 +118,10 @@ await ch.QueueBindAsync(queue: queueName,
                         {
                             nse = e;
                         }
+                        finally
+                        {
+                            await ch.CloseAsync();
+                        }
                     }
                 }
                 var t = Task.Run(f);
@@ -154,6 +158,10 @@ await ch.QueueUnbindAsync(queue: qname,
                         {
                             nse = e;
                         }
+                        finally
+                        {
+                            await ch.CloseAsync();
+                        }
                     }
                 }
                 var t = Task.Run(f);
@@ -190,6 +198,10 @@ public async Task TestConcurrentQueueDeclare()
                                 {
                                     nse = e;
                                 }
+                                finally
+                                {
+                                    await ch.CloseAsync();
+                                }
                             }
                         });
                 tasks.Add(t);
@@ -216,6 +228,10 @@ public async Task TestConcurrentQueueDeclare()
                                 {
                                     nse = e;
                                 }
+                                finally
+                                {
+                                    await ch.CloseAsync();
+                                }
                             }
                         });
                 tasks.Add(t);

projects/Test/Integration/TestToxiproxy.cs

@@ -225,8 +225,9 @@ public async Task TestThatStoppedSocketResultsInHeartbeatTimeout()
                             }
 
                             await ch.CloseAsync();
-                            await conn.CloseAsync();
                         }
+
+                        await conn.CloseAsync();
                     }
                 });