* Use TrySetException because tcs may have already completed.

lukebakken · lukebakken · commit eb5be9f1bfa4 · 2024-04-24T12:15:46.000-07:00
diff --git a/projects/RabbitMQ.Client/client/impl/AsyncRpcContinuations.cs b/projects/RabbitMQ.Client/client/impl/AsyncRpcContinuations.cs
@@ -111,7 +111,7 @@ public ConfiguredTaskAwaitable<T>.ConfiguredTaskAwaiter GetAwaiter()
 
         public virtual void HandleChannelShutdown(ShutdownEventArgs reason)
         {
-            _tcs.SetException(new OperationInterruptedException(reason));
+            _tcs.TrySetException(new OperationInterruptedException(reason));
         }
 
         protected virtual void Dispose(bool disposing)

Original file line number	Diff line number	Diff line change
`@@ -111,7 +111,7 @@ public ConfiguredTaskAwaitable<T>.ConfiguredTaskAwaiter GetAwaiter()`
`111`	`111`
`112`	`112`	`public virtual void HandleChannelShutdown(ShutdownEventArgs reason)`
`113`	`113`	`{`
`114`		`- _tcs.SetException(new OperationInterruptedException(reason));`
	`114`	`+ _tcs.TrySetException(new OperationInterruptedException(reason));`
`115`	`115`	`}`
`116`	`116`
`117`	`117`	`protected virtual void Dispose(bool disposing)`