Skip to content

Commit 9e21e8b

Browse files
SimonCroppSimonCropp
committed
use collection expressions where it improves performance
1 parent 4582deb commit 9e21e8b

57 files changed

Lines changed: 238 additions & 242 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎samples/TaskQueue/ASBTaskQueue/Greetings/Ports/CommandHandlers/AddGreetingCommandHandler.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ public async override Task<AddGreetingCommand> HandleAsync(AddGreetingCommand co
5050
await _unitOfWork.CommitAsync(cancellationToken);
5151

5252
//In Case there is no outbox Sweeper
53-
await _commandProcessor.ClearOutboxAsync(new[] {eventId}, cancellationToken: cancellationToken);
53+
await _commandProcessor.ClearOutboxAsync([eventId], cancellationToken: cancellationToken);
5454

5555
Console.WriteLine($"Message {command.GreetingMessage} Saved.");
5656
}

‎samples/TaskQueue/ASBTaskQueue/GreetingsSender.Web/Program.cs‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -42,12 +42,11 @@
4242

4343
var producerRegistry = new AzureServiceBusProducerRegistryFactory(
4444
asbConnection,
45-
new AzureServiceBusPublication[]
46-
{
45+
[
4746
new() { Topic = new RoutingKey("greeting.event"), MakeChannels = OnMissingChannel.Assume},
4847
new() { Topic = new RoutingKey("greeting.addGreetingCommand"), MakeChannels = OnMissingChannel.Assume },
4948
new() { Topic = new RoutingKey("greeting.Asyncevent"), MakeChannels = OnMissingChannel.Assume }
50-
}
49+
]
5150
)
5251
.Create();
5352

‎samples/TaskQueue/KafkaSchemaRegistry/GreetingsSender/Program.cs‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -94,18 +94,18 @@ THE SOFTWARE. */
9494

9595
static PolicyRegistry? RegisterPolicies()
9696
{
97-
var retryPolicy = Policy.Handle<Exception>().WaitAndRetry(new[]
98-
{
97+
var retryPolicy = Policy.Handle<Exception>().WaitAndRetry(
98+
[
9999
TimeSpan.FromMilliseconds(50), TimeSpan.FromMilliseconds(100), TimeSpan.FromMilliseconds(150)
100-
});
100+
]);
101101

102102
var circuitBreakerPolicy =
103103
Policy.Handle<Exception>().CircuitBreaker(1, TimeSpan.FromMilliseconds(500));
104104

105-
var retryPolicyAsync = Policy.Handle<Exception>().WaitAndRetryAsync(new[]
106-
{
105+
var retryPolicyAsync = Policy.Handle<Exception>().WaitAndRetryAsync(
106+
[
107107
TimeSpan.FromMilliseconds(50), TimeSpan.FromMilliseconds(100), TimeSpan.FromMilliseconds(150)
108-
});
108+
]);
109109

110110
var circuitBreakerPolicyAsync = Policy.Handle<Exception>()
111111
.CircuitBreakerAsync(1, TimeSpan.FromMilliseconds(500));

‎samples/TaskQueue/KafkaTaskQueue/GreetingsSender/Program.cs‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -53,18 +53,18 @@ THE SOFTWARE. */
5353
})
5454
.ConfigureServices((hostContext, services) =>
5555
{
56-
var retryPolicy = Policy.Handle<Exception>().WaitAndRetry(new[]
57-
{
56+
var retryPolicy = Policy.Handle<Exception>().WaitAndRetry(
57+
[
5858
TimeSpan.FromMilliseconds(50), TimeSpan.FromMilliseconds(100), TimeSpan.FromMilliseconds(150)
59-
});
59+
]);
6060

6161
var circuitBreakerPolicy =
6262
Policy.Handle<Exception>().CircuitBreaker(1, TimeSpan.FromMilliseconds(500));
6363

64-
var retryPolicyAsync = Policy.Handle<Exception>().WaitAndRetryAsync(new[]
65-
{
64+
var retryPolicyAsync = Policy.Handle<Exception>().WaitAndRetryAsync(
65+
[
6666
TimeSpan.FromMilliseconds(50), TimeSpan.FromMilliseconds(100), TimeSpan.FromMilliseconds(150)
67-
});
67+
]);
6868

6969
var circuitBreakerPolicyAsync = Policy.Handle<Exception>()
7070
.CircuitBreakerAsync(1, TimeSpan.FromMilliseconds(500));

‎samples/TaskQueue/MsSqlMessagingGateway/CompetingSender/Program.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ private static async Task Main(string[] args)
4646

4747
var producerRegistry = new MsSqlProducerRegistryFactory(
4848
messagingConfiguration,
49-
new Publication[]{new Publication()})
49+
[new Publication()])
5050
.Create();
5151

5252
services.AddBrighter()

‎samples/TaskQueue/MultiBus/GreetingsSender/Program.cs‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -54,18 +54,18 @@ THE SOFTWARE. */
5454
})
5555
.ConfigureServices((_, services) =>
5656
{
57-
var retryPolicy = Policy.Handle<Exception>().WaitAndRetry(new[]
58-
{
57+
var retryPolicy = Policy.Handle<Exception>().WaitAndRetry(
58+
[
5959
TimeSpan.FromMilliseconds(50), TimeSpan.FromMilliseconds(100), TimeSpan.FromMilliseconds(150)
60-
});
60+
]);
6161

6262
var circuitBreakerPolicy =
6363
Policy.Handle<Exception>().CircuitBreaker(1, TimeSpan.FromMilliseconds(500));
6464

65-
var retryPolicyAsync = Policy.Handle<Exception>().WaitAndRetryAsync(new[]
66-
{
65+
var retryPolicyAsync = Policy.Handle<Exception>().WaitAndRetryAsync(
66+
[
6767
TimeSpan.FromMilliseconds(50), TimeSpan.FromMilliseconds(100), TimeSpan.FromMilliseconds(150)
68-
});
68+
]);
6969

7070
var circuitBreakerPolicyAsync = Policy.Handle<Exception>()
7171
.CircuitBreakerAsync(1, TimeSpan.FromMilliseconds(500));

‎samples/TaskQueue/RedisTaskQueue/GreetingsSender/Program.cs‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -91,14 +91,13 @@ private static IHostBuilder CreateHostBuilder(string[] args) =>
9191

9292
var producerRegistry = new RedisProducerRegistryFactory(
9393
redisConnection,
94-
new RedisMessagePublication[]
95-
{
94+
[
9695
new()
9796
{
9897
Topic = new RoutingKey("greeting.event"),
9998
RequestType = typeof(GreetingEvent)
10099
}
101-
}
100+
]
102101
).Create();
103102

104103
collection.AddBrighter()

‎samples/Transforms/AWSTransfomers/ClaimCheck/GreetingsSender/Program.cs‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -63,16 +63,15 @@ static void Main(string[] args)
6363

6464
var producerRegistry = new SnsProducerRegistryFactory(
6565
awsConnection,
66-
new SnsPublication[]
67-
{
66+
[
6867
new()
6968
{
7069
Topic = topic,
7170
RequestType = typeof(GreetingEvent),
7271
FindTopicBy = TopicFindBy.Convention,
7372
MakeChannels = OnMissingChannel.Create
7473
}
75-
}
74+
]
7675
).Create();
7776

7877
serviceCollection.AddBrighter()

‎samples/Transforms/AWSTransfomers/CloudEvents/GreetingsSender/Program.cs‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -62,16 +62,15 @@ static void Main(string[] args)
6262

6363
var producerRegistry = new SnsProducerRegistryFactory(
6464
awsConnection,
65-
new SnsPublication[]
66-
{
65+
[
6766
new()
6867
{
6968
Topic = topic,
7069
RequestType = typeof(GreetingEvent),
7170
FindTopicBy = TopicFindBy.Convention,
7271
MakeChannels = OnMissingChannel.Create
7372
}
74-
}
73+
]
7574
).Create();
7675

7776
serviceCollection.AddBrighter()

‎samples/Transforms/AWSTransfomers/Compression/GreetingsSender/Program.cs‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -62,16 +62,15 @@ static void Main(string[] args)
6262

6363
var producerRegistry = new SnsProducerRegistryFactory(
6464
awsConnection,
65-
new SnsPublication[]
66-
{
65+
[
6766
new()
6867
{
6968
Topic = topic,
7069
RequestType = typeof(GreetingEvent),
7170
FindTopicBy = TopicFindBy.Convention,
7271
MakeChannels = OnMissingChannel.Create
7372
}
74-
}
73+
]
7574
).Create();
7675

7776
serviceCollection.AddBrighter()

0 commit comments

Comments
 (0)