@@ -471,7 +471,7 @@ protected ValueTask ModelSendAsync<T>(in T method, CancellationToken cancellatio
471
471
}
472
472
473
473
[ MethodImpl ( MethodImplOptions . AggressiveInlining ) ]
474
- protected ValueTask ModelSendAsync < TMethod , THeader > ( in TMethod method , in THeader header , ReadOnlyMemory < byte > body , CancellationToken cancellationToken )
474
+ protected ValueTask ModelSendObserveFlowControlAsync < TMethod , THeader > ( in TMethod method , in THeader header , ReadOnlyMemory < byte > body , CancellationToken cancellationToken )
475
475
where TMethod : struct , IOutgoingAmqpMethod
476
476
where THeader : IAmqpHeader
477
477
{
@@ -964,18 +964,18 @@ await _confirmSemaphore.WaitAsync(cancellationToken)
964
964
BasicProperties ? props = PopulateActivityAndPropagateTraceId ( basicProperties , sendActivity ) ;
965
965
if ( props is null )
966
966
{
967
- await ModelSendAsync ( in cmd , in basicProperties , body , cancellationToken )
967
+ await ModelSendObserveFlowControlAsync ( in cmd , in basicProperties , body , cancellationToken )
968
968
. ConfigureAwait ( false ) ;
969
969
}
970
970
else
971
971
{
972
- await ModelSendAsync ( in cmd , in props , body , cancellationToken )
972
+ await ModelSendObserveFlowControlAsync ( in cmd , in props , body , cancellationToken )
973
973
. ConfigureAwait ( false ) ;
974
974
}
975
975
}
976
976
else
977
977
{
978
- await ModelSendAsync ( in cmd , in basicProperties , body , cancellationToken )
978
+ await ModelSendObserveFlowControlAsync ( in cmd , in basicProperties , body , cancellationToken )
979
979
. ConfigureAwait ( false ) ;
980
980
}
981
981
}
@@ -1043,18 +1043,18 @@ await _confirmSemaphore.WaitAsync(cancellationToken)
1043
1043
BasicProperties ? props = PopulateActivityAndPropagateTraceId ( basicProperties , sendActivity ) ;
1044
1044
if ( props is null )
1045
1045
{
1046
- await ModelSendAsync ( in cmd , in basicProperties , body , cancellationToken )
1046
+ await ModelSendObserveFlowControlAsync ( in cmd , in basicProperties , body , cancellationToken )
1047
1047
. ConfigureAwait ( false ) ;
1048
1048
}
1049
1049
else
1050
1050
{
1051
- await ModelSendAsync ( in cmd , in props , body , cancellationToken )
1051
+ await ModelSendObserveFlowControlAsync ( in cmd , in props , body , cancellationToken )
1052
1052
. ConfigureAwait ( false ) ;
1053
1053
}
1054
1054
}
1055
1055
else
1056
1056
{
1057
- await ModelSendAsync ( in cmd , in basicProperties , body , cancellationToken )
1057
+ await ModelSendObserveFlowControlAsync ( in cmd , in basicProperties , body , cancellationToken )
1058
1058
. ConfigureAwait ( false ) ;
1059
1059
}
1060
1060
}
0 commit comments