* Remove TCS from _confirmsTaskCompletionSources if there is an OperationCanceledException.

lukebakken · lukebakken · commit 13de610331d7 · 2025-03-28T13:36:30.000-07:00
diff --git a/projects/RabbitMQ.Client/Impl/Channel.PublisherConfirms.cs b/projects/RabbitMQ.Client/Impl/Channel.PublisherConfirms.cs
@@ -380,6 +380,11 @@ private async Task MaybeEndPublisherConfirmationTracking(PublisherConfirmationIn
                         await publisherConfirmationInfo.MaybeWaitForConfirmationAsync(cancellationToken)
                             .ConfigureAwait(false);
                     }
+                    catch (OperationCanceledException)
+                    {
+                        _confirmsTaskCompletionSources.Remove(publisherConfirmationInfo.PublishSequenceNumber, out _);
+                        throw;
+                    }
                     finally
                     {
                         publisherConfirmationInfo.Dispose();

Original file line number	Diff line number	Diff line change
`@@ -380,6 +380,11 @@ private async Task MaybeEndPublisherConfirmationTracking(PublisherConfirmationIn`
`380`	`380`	`await publisherConfirmationInfo.MaybeWaitForConfirmationAsync(cancellationToken)`
`381`	`381`	`.ConfigureAwait(false);`
`382`	`382`	`}`
	`383`	`+ catch (OperationCanceledException)`
	`384`	`+ {`
	`385`	`+ _confirmsTaskCompletionSources.Remove(publisherConfirmationInfo.PublishSequenceNumber, out _);`
	`386`	`+ throw;`
	`387`	`+ }`
`383`	`388`	`finally`
`384`	`389`	`{`
`385`	`390`	`publisherConfirmationInfo.Dispose();`