Skip to content

Commit 550ba8c

Browse files
committed
Adjust channel to use new async primitive
1 parent 3bb87cb commit 550ba8c

File tree

2 files changed

+67
-50
lines changed

2 files changed

+67
-50
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -47,21 +47,21 @@ public override ValueTask BasicAckAsync(ulong deliveryTag, bool multiple,
4747
CancellationToken cancellationToken)
4848
{
4949
var method = new BasicAck(deliveryTag, multiple);
50-
return ModelSendAsync(method, cancellationToken);
50+
return ModelSendAsync(in method, cancellationToken);
5151
}
5252

5353
public override ValueTask BasicNackAsync(ulong deliveryTag, bool multiple, bool requeue,
5454
CancellationToken cancellationToken)
5555
{
5656
var method = new BasicNack(deliveryTag, multiple, requeue);
57-
return ModelSendAsync(method, cancellationToken);
57+
return ModelSendAsync(in method, cancellationToken);
5858
}
5959

6060
public override ValueTask BasicRejectAsync(ulong deliveryTag, bool requeue,
6161
CancellationToken cancellationToken)
6262
{
6363
var method = new BasicReject(deliveryTag, requeue);
64-
return ModelSendAsync(method, cancellationToken);
64+
return ModelSendAsync(in method, cancellationToken);
6565
}
6666

6767
/// <summary>

0 commit comments

Comments
 (0)