Propagate value task

danielmarbach · danielmarbach · commit 1b0c47ae8c62 · 2024-09-18T15:20:21.000+02:00
diff --git a/projects/RabbitMQ.Client/client/impl/ChannelBase.cs b/projects/RabbitMQ.Client/client/impl/ChannelBase.cs
@@ -458,13 +458,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 void OnCallbackException(CallbackExceptionEventArgs args)

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