Propagate value task

danielmarbach · danielmarbach · commit 13ec02368ba0 · 2024-09-18T19:40:02.000Z
diff --git a/projects/RabbitMQ.Client/client/impl/ChannelBase.cs b/projects/RabbitMQ.Client/client/impl/ChannelBase.cs
@@ -459,13 +459,14 @@ protected ValueTask ModelSendAsync<TMethod, THeader>(in TMethod method, in THead
         }
 
         [MethodImpl(MethodImplOptions.AggressiveInlining)]
-        protected async Task FlowControlAsync(CancellationToken cancellationToken)
+        protected ValueTask FlowControlAsync(CancellationToken cancellationToken)
         {
-            if (!_flowControlBlock.IsSet)
+            if (_flowControlBlock.IsSet)
             {
-                await _flowControlBlock.WaitAsync(cancellationToken)
-                    .ConfigureAwait(false);
+                return new ValueTask();
             }
+
+            return _flowControlBlock.WaitAsync(cancellationToken);
         }
 
         internal Task OnCallbackExceptionAsync(CallbackExceptionEventArgs args)

Original file line number	Diff line number	Diff line change
`@@ -459,13 +459,14 @@ protected ValueTask ModelSendAsync<TMethod, THeader>(in TMethod method, in THead`
`459`	`459`	`}`
`460`	`460`
`461`	`461`	`[MethodImpl(MethodImplOptions.AggressiveInlining)]`
`462`		`- protected async Task FlowControlAsync(CancellationToken cancellationToken)`
	`462`	`+ protected ValueTask FlowControlAsync(CancellationToken cancellationToken)`
`463`	`463`	`{`
`464`		`- if (!_flowControlBlock.IsSet)`
	`464`	`+ if (_flowControlBlock.IsSet)`
`465`	`465`	`{`
`466`		`- await _flowControlBlock.WaitAsync(cancellationToken)`
`467`		`- .ConfigureAwait(false);`
	`466`	`+ return new ValueTask();`
`468`	`467`	`}`
	`468`	`+`
	`469`	`+ return _flowControlBlock.WaitAsync(cancellationToken);`
`469`	`470`	`}`
`470`	`471`
`471`	`472`	`internal Task OnCallbackExceptionAsync(CallbackExceptionEventArgs args)`