Skip to content

Commit 2f55690

Browse files
committed
All methods that return Tasks should have the Async suffix #1296
1 parent 5e0f118 commit 2f55690

File tree

3 files changed

+5
-6
lines changed

3 files changed

+5
-6
lines changed

projects/RabbitMQ.Client/client/impl/Connection.Commands.cs

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,6 @@
3737
using RabbitMQ.Client.Exceptions;
3838
using RabbitMQ.Client.Impl;
3939
using RabbitMQ.Client.Logging;
40-
using RabbitMQ.Util;
4140

4241
namespace RabbitMQ.Client.Framing.Impl
4342
{
@@ -74,17 +73,17 @@ internal void HandleConnectionUnblocked()
7473
private async ValueTask OpenAsync()
7574
{
7675
RabbitMqClientEventSource.Log.ConnectionOpened();
77-
await StartAndTune().ConfigureAwait(false);
76+
await StartAndTuneAsync().ConfigureAwait(false);
7877
await _channel0.ConnectionOpenAsync(_config.VirtualHost);
7978
}
8079

81-
private async ValueTask StartAndTune()
80+
private async ValueTask StartAndTuneAsync()
8281
{
8382
var connectionStartCell = new TaskCompletionSource<ConnectionStartDetails>(TaskCreationOptions.RunContinuationsAsynchronously);
8483
_channel0.m_connectionStartCell = connectionStartCell;
8584
_channel0.HandshakeContinuationTimeout = _config.HandshakeContinuationTimeout;
8685
_frameHandler.ReadTimeout = _config.HandshakeContinuationTimeout;
87-
await _frameHandler.SendHeader().ConfigureAwait(false);
86+
await _frameHandler.SendHeaderAsync().ConfigureAwait(false);
8887
ConnectionStartDetails connectionStart = await connectionStartCell.Task.ConfigureAwait(false);
8988

9089
if (connectionStart is null)

projects/RabbitMQ.Client/client/impl/IFrameHandler.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ internal interface IFrameHandler
6565
///</summary>
6666
bool TryReadFrame(out InboundFrame frame);
6767

68-
ValueTask SendHeader();
68+
ValueTask SendHeaderAsync();
6969

7070
ValueTask WriteAsync(ReadOnlyMemory<byte> memory);
7171
}

projects/RabbitMQ.Client/client/impl/SocketFrameHandler.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -272,7 +272,7 @@ public bool TryReadFrame(out InboundFrame frame)
272272
return InboundFrame.TryReadFrameFromPipe(_pipeReader, _amqpTcpEndpoint.MaxMessageSize, out frame);
273273
}
274274

275-
public async ValueTask SendHeader()
275+
public async ValueTask SendHeaderAsync()
276276
{
277277
_pipeWriter.Write(ProtocolHeader);
278278
await _pipeWriter.FlushAsync().ConfigureAwait(false);

0 commit comments

Comments
 (0)