Support cancellation on the flow control block

danielmarbach · danielmarbach · commit f68df3919217 · 2024-07-30T15:17:55.000+02:00
diff --git a/projects/RabbitMQ.Client/client/impl/ChannelBase.cs b/projects/RabbitMQ.Client/client/impl/ChannelBase.cs
@@ -453,7 +453,7 @@ protected ValueTask ModelSendAsync<TMethod, THeader>(in TMethod method, in THead
         {
             if (!_flowControlBlock.IsSet)
             {
-                _flowControlBlock.Wait();
+                _flowControlBlock.Wait(cancellationToken);
             }
 
             return Session.TransmitAsync(in method, in header, body, cancellationToken);

Original file line number	Diff line number	Diff line change
`@@ -453,7 +453,7 @@ protected ValueTask ModelSendAsync<TMethod, THeader>(in TMethod method, in THead`
`453`	`453`	`{`
`454`	`454`	`if (!_flowControlBlock.IsSet)`
`455`	`455`	`{`
`456`		`- _flowControlBlock.Wait();`
	`456`	`+ _flowControlBlock.Wait(cancellationToken);`
`457`	`457`	`}`
`458`	`458`
`459`	`459`	`return Session.TransmitAsync(in method, in header, body, cancellationToken);`