Support cancellation on the flow control block

rabbitmq · Jul 30, 2024 · 8c6e061 · 8c6e061
1 parent f2cf79a
commit 8c6e061
Showing 1 changed file with 1 addition and 1 deletion.
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);