Added TryComplete instead of comple during channel shutdown

Patrik Tiainen · Patrik Tiainen · commit 1e676e4593b7 · 2025-12-09T09:51:11.000+01:00
diff --git 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;
         }
 

Original file line number	Diff line number	Diff line change
`@@ -228,7 +228,7 @@ protected sealed override void ShutdownConsumer(IAsyncBasicConsumer consumer, Sh`
`228`	`228`
`229`	`229`	`protected override Task InternalShutdownAsync()`
`230`	`230`	`{`
`231`		`- _writer.Complete();`
	`231`	`+ _writer.TryComplete();`
`232`	`232`	`return _worker;`
`233`	`233`	`}`
`234`	`234`