Skip to content

Commit 619e5e7

Browse files
committed
Reverting interface changes.
1 parent a7b405b commit 619e5e7

File tree

5 files changed

+2
-11
lines changed

5 files changed

+2
-11
lines changed

projects/RabbitMQ.Client/client/api/AsyncDefaultBasicConsumer.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ public virtual Task HandleBasicConsumeOk(string consumerTag)
9696
{
9797
_consumerTags.Add(consumerTag);
9898
IsRunning = true;
99-
return TaskExtensions.CompletedTask;
99+
return Task.CompletedTask;
100100
}
101101

102102
/// <summary>
@@ -118,7 +118,7 @@ public virtual Task HandleBasicDeliver(string consumerTag,
118118
ReadOnlyMemory<byte> body)
119119
{
120120
// Nothing to do here.
121-
return TaskExtensions.CompletedTask;
121+
return Task.CompletedTask;
122122
}
123123

124124
/// <summary>

projects/RabbitMQ.Client/client/api/IBasicPublishBatch.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,6 @@ namespace RabbitMQ.Client
4444
public interface IBasicPublishBatch
4545
{
4646
void Add(string exchange, string routingKey, bool mandatory, IBasicProperties properties, byte[] body);
47-
void Add(string exchange, string routingKey, bool mandatory, IBasicProperties properties, ReadOnlyMemory<byte> body);
4847
void Publish();
4948
}
5049
}

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

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -56,11 +56,6 @@ internal BasicPublishBatch (ModelBase model)
5656
}
5757

5858
public void Add(string exchange, string routingKey, bool mandatory, IBasicProperties basicProperties, byte[] body)
59-
{
60-
Add(exchange, routingKey, mandatory, basicProperties, body.AsMemory());
61-
}
62-
63-
public void Add(string exchange, string routingKey, bool mandatory, IBasicProperties basicProperties, ReadOnlyMemory<byte> body)
6459
{
6560
IBasicProperties bp = basicProperties ?? _model.CreateBasicProperties();
6661
var method = new BasicPublish

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,8 +54,6 @@ namespace RabbitMQ.Client.Impl
5454
{
5555
static class TaskExtensions
5656
{
57-
public static Task CompletedTask = Task.FromResult(0);
58-
5957
public static async Task TimeoutAfter(this Task task, TimeSpan timeout)
6058
{
6159
if (task == await Task.WhenAny(task, Task.Delay(timeout)).ConfigureAwait(false))

projects/Unit/APIApproval.Approve.verified.txt

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -259,7 +259,6 @@ namespace RabbitMQ.Client
259259
public interface IBasicPublishBatch
260260
{
261261
void Add(string exchange, string routingKey, bool mandatory, RabbitMQ.Client.IBasicProperties properties, byte[] body);
262-
void Add(string exchange, string routingKey, bool mandatory, RabbitMQ.Client.IBasicProperties properties, System.ReadOnlyMemory<byte> body);
263262
void Publish();
264263
}
265264
public interface IConnection : RabbitMQ.Client.INetworkConnection, System.IDisposable

0 commit comments

Comments
 (0)