Rename to fix conflict with event.

lukebakken · lukebakken · commit a15c1f8d0b12 · 2024-09-18T12:43:18.000-07:00
diff --git a/projects/RabbitMQ.Client/client/impl/ChannelBase.cs b/projects/RabbitMQ.Client/client/impl/ChannelBase.cs
@@ -459,7 +459,7 @@ protected ValueTask ModelSendAsync<TMethod, THeader>(in TMethod method, in THead
         }
 
         [MethodImpl(MethodImplOptions.AggressiveInlining)]
-        protected ValueTask FlowControlAsync(CancellationToken cancellationToken)
+        protected ValueTask EnforceFlowControlAsync(CancellationToken cancellationToken)
         {
             if (_flowControlBlock.IsSet)
             {
@@ -991,22 +991,22 @@ await _confirmSemaphore.WaitAsync(cancellationToken)
                     BasicProperties? props = PopulateActivityAndPropagateTraceId(basicProperties, sendActivity);
                     if (props is null)
                     {
-                        await FlowControlAsync(cancellationToken)
+                        await EnforceFlowControlAsync(cancellationToken)
                             .ConfigureAwait(false);
                         await ModelSendAsync(in cmd, in basicProperties, body, cancellationToken)
                             .ConfigureAwait(false);
                     }
                     else
                     {
-                        await FlowControlAsync(cancellationToken)
+                        await EnforceFlowControlAsync(cancellationToken)
                             .ConfigureAwait(false);
                         await ModelSendAsync(in cmd, in props, body, cancellationToken)
                             .ConfigureAwait(false);
                     }
                 }
                 else
                 {
-                    await FlowControlAsync(cancellationToken)
+                    await EnforceFlowControlAsync(cancellationToken)
                         .ConfigureAwait(false);
                     await ModelSendAsync(in cmd, in basicProperties, body, cancellationToken)
                         .ConfigureAwait(false);
@@ -1076,22 +1076,22 @@ await _confirmSemaphore.WaitAsync(cancellationToken)
                     BasicProperties? props = PopulateActivityAndPropagateTraceId(basicProperties, sendActivity);
                     if (props is null)
                     {
-                        await FlowControlAsync(cancellationToken)
+                        await EnforceFlowControlAsync(cancellationToken)
                             .ConfigureAwait(false);
                         await ModelSendAsync(in cmd, in basicProperties, body, cancellationToken)
                             .ConfigureAwait(false);
                     }
                     else
                     {
-                        await FlowControlAsync(cancellationToken)
+                        await EnforceFlowControlAsync(cancellationToken)
                             .ConfigureAwait(false);
                         await ModelSendAsync(in cmd, in props, body, cancellationToken)
                             .ConfigureAwait(false);
                     }
                 }
                 else
                 {
-                    await FlowControlAsync(cancellationToken)
+                    await EnforceFlowControlAsync(cancellationToken)
                         .ConfigureAwait(false);
                     await ModelSendAsync(in cmd, in basicProperties, body, cancellationToken)
                         .ConfigureAwait(false);

Original file line number	Diff line number	Diff line change
`@@ -459,7 +459,7 @@ protected ValueTask ModelSendAsync<TMethod, THeader>(in TMethod method, in THead`
`459`	`459`	`}`
`460`	`460`
`461`	`461`	`[MethodImpl(MethodImplOptions.AggressiveInlining)]`
`462`		`- protected ValueTask FlowControlAsync(CancellationToken cancellationToken)`
	`462`	`+ protected ValueTask EnforceFlowControlAsync(CancellationToken cancellationToken)`
`463`	`463`	`{`
`464`	`464`	`if (_flowControlBlock.IsSet)`
`465`	`465`	`{`
`@@ -991,22 +991,22 @@ await _confirmSemaphore.WaitAsync(cancellationToken)`
`991`	`991`	`BasicProperties? props = PopulateActivityAndPropagateTraceId(basicProperties, sendActivity);`
`992`	`992`	`if (props is null)`
`993`	`993`	`{`
`994`		`- await FlowControlAsync(cancellationToken)`
	`994`	`+ await EnforceFlowControlAsync(cancellationToken)`
`995`	`995`	`.ConfigureAwait(false);`
`996`	`996`	`await ModelSendAsync(in cmd, in basicProperties, body, cancellationToken)`
`997`	`997`	`.ConfigureAwait(false);`
`998`	`998`	`}`
`999`	`999`	`else`
`1000`	`1000`	`{`
`1001`		`- await FlowControlAsync(cancellationToken)`
	`1001`	`+ await EnforceFlowControlAsync(cancellationToken)`
`1002`	`1002`	`.ConfigureAwait(false);`
`1003`	`1003`	`await ModelSendAsync(in cmd, in props, body, cancellationToken)`
`1004`	`1004`	`.ConfigureAwait(false);`
`1005`	`1005`	`}`
`1006`	`1006`	`}`
`1007`	`1007`	`else`
`1008`	`1008`	`{`
`1009`		`- await FlowControlAsync(cancellationToken)`
	`1009`	`+ await EnforceFlowControlAsync(cancellationToken)`
`1010`	`1010`	`.ConfigureAwait(false);`
`1011`	`1011`	`await ModelSendAsync(in cmd, in basicProperties, body, cancellationToken)`
`1012`	`1012`	`.ConfigureAwait(false);`
`@@ -1076,22 +1076,22 @@ await _confirmSemaphore.WaitAsync(cancellationToken)`
`1076`	`1076`	`BasicProperties? props = PopulateActivityAndPropagateTraceId(basicProperties, sendActivity);`
`1077`	`1077`	`if (props is null)`
`1078`	`1078`	`{`
`1079`		`- await FlowControlAsync(cancellationToken)`
	`1079`	`+ await EnforceFlowControlAsync(cancellationToken)`
`1080`	`1080`	`.ConfigureAwait(false);`
`1081`	`1081`	`await ModelSendAsync(in cmd, in basicProperties, body, cancellationToken)`
`1082`	`1082`	`.ConfigureAwait(false);`
`1083`	`1083`	`}`
`1084`	`1084`	`else`
`1085`	`1085`	`{`
`1086`		`- await FlowControlAsync(cancellationToken)`
	`1086`	`+ await EnforceFlowControlAsync(cancellationToken)`
`1087`	`1087`	`.ConfigureAwait(false);`
`1088`	`1088`	`await ModelSendAsync(in cmd, in props, body, cancellationToken)`
`1089`	`1089`	`.ConfigureAwait(false);`
`1090`	`1090`	`}`
`1091`	`1091`	`}`
`1092`	`1092`	`else`
`1093`	`1093`	`{`
`1094`		`- await FlowControlAsync(cancellationToken)`
	`1094`	`+ await EnforceFlowControlAsync(cancellationToken)`
`1095`	`1095`	`.ConfigureAwait(false);`
`1096`	`1096`	`await ModelSendAsync(in cmd, in basicProperties, body, cancellationToken)`
`1097`	`1097`	`.ConfigureAwait(false);`