diff --git a/projects/RabbitMQ.Client/ConsumerDispatching/ConsumerDispatcherChannelBase.cs b/projects/RabbitMQ.Client/ConsumerDispatching/ConsumerDispatcherChannelBase.cs
index be9ebf802..9c807d3b2 100644
--- a/projects/RabbitMQ.Client/ConsumerDispatching/ConsumerDispatcherChannelBase.cs
+++ b/projects/RabbitMQ.Client/ConsumerDispatching/ConsumerDispatcherChannelBase.cs
@@ -228,7 +228,7 @@ protected sealed override void ShutdownConsumer(IAsyncBasicConsumer consumer, Sh
 
         protected override Task InternalShutdownAsync()
         {
-            _writer.Complete();
+            _writer.TryComplete();
             return _worker;
         }