Skip to content

Commit 48ee0d0

Browse files
committed
* Making HandleChannleClose async
1 parent c8ce6d8 commit 48ee0d0

File tree

2 files changed

+6
-5
lines changed

2 files changed

+6
-5
lines changed

projects/RabbitMQ.Client/client/framing/Channel.cs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,9 +48,10 @@ public override Task ConnectionTuneOkAsync(ushort channelMax, uint frameMax, ush
4848
return ModelSendAsync(method, cancellationToken).AsTask();
4949
}
5050

51-
public override void _Private_ChannelCloseOk()
51+
public override Task _Private_ChannelCloseOkAsync(CancellationToken cancellationToken)
5252
{
53-
ChannelSend(new ChannelCloseOk());
53+
var method = new ChannelCloseOk();
54+
return ModelSendAsync(method, cancellationToken).AsTask();
5455
}
5556

5657
public override void _Private_ChannelFlowOk(bool active)

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -769,7 +769,8 @@ protected void HandleChannelClose(in IncomingCommand cmd)
769769

770770
Session.Close(CloseReason, false);
771771

772-
_Private_ChannelCloseOk();
772+
// TODO async
773+
_Private_ChannelCloseOkAsync(CancellationToken.None).EnsureCompleted();
773774
}
774775
finally
775776
{
@@ -952,8 +953,7 @@ protected bool HandleQueueDeclareOk(in IncomingCommand cmd)
952953
}
953954
}
954955

955-
// TODO async
956-
public abstract void _Private_ChannelCloseOk();
956+
public abstract Task _Private_ChannelCloseOkAsync(CancellationToken cancellationToken);
957957

958958
// TODO async
959959
public abstract void _Private_ChannelFlowOk(bool active);

0 commit comments

Comments
 (0)