Rename three internal async methods to use Async suffix.

rabbitmq · Sep 17, 2024 · 7337fad · 7337fad
1 parent 830b1e4
commit 7337fad
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/projects/RabbitMQ.Client/client/framing/Channel.cs b/projects/RabbitMQ.Client/client/framing/Channel.cs
@@ -118,7 +118,7 @@ protected override Task<bool> DispatchCommandAsync(IncomingCommand cmd, Cancella
                 case ProtocolCommandId.ConnectionBlocked:
                     {
                         // Note: always returns true
-                        return HandleConnectionBlocked(cmd, cancellationToken);
+                        return HandleConnectionBlockedAsync(cmd, cancellationToken);
                     }
                 case ProtocolCommandId.ConnectionClose:
                     {
@@ -143,7 +143,7 @@ protected override Task<bool> DispatchCommandAsync(IncomingCommand cmd, Cancella
                 case ProtocolCommandId.ConnectionUnblocked:
                     {
                         // Note: always returns true
-                        return HandleConnectionUnblocked(cancellationToken);
+                        return HandleConnectionUnblockedAsync(cancellationToken);
                     }
                 default:
                     {

diff --git a/projects/RabbitMQ.Client/client/impl/ChannelBase.cs b/projects/RabbitMQ.Client/client/impl/ChannelBase.cs
@@ -701,10 +701,10 @@ await ModelSendAsync(method, cancellationToken).
             return true;
         }
 
-        protected async Task<bool> HandleConnectionBlocked(IncomingCommand cmd, CancellationToken cancellationToken)
+        protected async Task<bool> HandleConnectionBlockedAsync(IncomingCommand cmd, CancellationToken cancellationToken)
         {
             string reason = new ConnectionBlocked(cmd.MethodSpan)._reason;
-            await Session.Connection.HandleConnectionBlocked(reason)
+            await Session.Connection.HandleConnectionBlockedAsync(reason)
                 .ConfigureAwait(false);
             return true;
         }
@@ -780,9 +780,9 @@ await k.HandleCommandAsync(cmd)
             return true;
         }
 
-        protected async Task<bool> HandleConnectionUnblocked(CancellationToken cancellationToken)
+        protected async Task<bool> HandleConnectionUnblockedAsync(CancellationToken cancellationToken)
         {
-            await Session.Connection.HandleConnectionUnblocked()
+            await Session.Connection.HandleConnectionUnblockedAsync()
                 .ConfigureAwait(false);
             return true;
         }

diff --git a/projects/RabbitMQ.Client/client/impl/Connection.Commands.cs b/projects/RabbitMQ.Client/client/impl/Connection.Commands.cs
@@ -54,7 +54,7 @@ internal void NotifyReceivedCloseOk()
             _closed = true;
         }
 
-        internal Task HandleConnectionBlocked(string reason)
+        internal Task HandleConnectionBlockedAsync(string reason)
         {
             if (!_connectionBlockedWrapper.IsEmpty)
             {
@@ -63,7 +63,7 @@ internal Task HandleConnectionBlocked(string reason)
             return Task.CompletedTask;
         }
 
-        internal Task HandleConnectionUnblocked()
+        internal Task HandleConnectionUnblockedAsync()
         {
             if (!_connectionUnblockedWrapper.IsEmpty)
             {