Skip to content

Commit ad587ac

Browse files
authored
Removed unnecessary lambda expressions (#8402)
1 parent 05f7b62 commit ad587ac

File tree

21 files changed

+145
-148
lines changed

21 files changed

+145
-148
lines changed

.editorconfig

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -218,6 +218,8 @@ dotnet_diagnostic.IDE0079.severity = warning
218218
dotnet_remove_unnecessary_suppression_exclusions = CA1822, InconsistentNaming, RCS1102, xUnit1044
219219
# Use pattern matching (not operator).
220220
dotnet_diagnostic.IDE0083.severity = warning
221+
# Remove unnecessary lambda expression.
222+
dotnet_diagnostic.IDE0200.severity = warning
221223
# Use collection expression for array.
222224
dotnet_diagnostic.IDE0300.severity = warning
223225
# Use collection expression for empty.

src/HotChocolate/Core/src/Execution/Processing/Tasks/StreamHelper.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ internal static class StreamHelper
2222
public static IAsyncEnumerable<object?> CreateStream(object result)
2323
{
2424
var resultType = result.GetType();
25-
var factory = s_streamFactories.GetOrAdd(resultType, t => CreateFactory(t));
25+
var factory = s_streamFactories.GetOrAdd(resultType, CreateFactory);
2626
return factory.Invoke(result);
2727
}
2828

src/HotChocolate/Core/src/Subscriptions.Postgres/PostgresChannel.cs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -78,9 +78,7 @@ private async ValueTask OnConnect(CancellationToken cancellationToken = default)
7878
_subscription = new ChannelSubscription(_channelName, connection, OnNotification);
7979
await _subscription.ConnectAsync(cancellationToken);
8080

81-
_waitOnNotificationTask = new ContinuousTask(
82-
ct => connection.WaitAsync(ct),
83-
TimeProvider.System);
81+
_waitOnNotificationTask = new ContinuousTask(connection.WaitAsync, TimeProvider.System);
8482

8583
_diagnosticEvents.ProviderInfo(PostgresChannel_ConnectionEstablished);
8684
}

src/HotChocolate/Core/src/Types/Configuration/TypeInitializer.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -219,7 +219,7 @@ private void CompleteNames()
219219
{
220220
_interceptor.OnBeforeCompleteTypeNames();
221221

222-
if (ProcessTypes(Named, type => CompleteTypeName(type)))
222+
if (ProcessTypes(Named, CompleteTypeName))
223223
{
224224
_interceptor.OnTypesCompletedName();
225225
}
@@ -575,7 +575,7 @@ private void CompleteTypes()
575575
{
576576
_interceptor.OnBeforeCompleteTypes();
577577

578-
if (ProcessTypes(Completed, type => CompleteType(type)))
578+
if (ProcessTypes(Completed, CompleteType))
579579
{
580580
_interceptor.OnTypesCompleted();
581581
}

src/HotChocolate/Core/src/Types/Utilities/DefaultTypeConverter.Setup.cs

Lines changed: 110 additions & 110 deletions
Large diffs are not rendered by default.

src/HotChocolate/Core/test/Features.Tests/FeatureCollectionExtensionsTests.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,6 @@ public void ExceptionThrown_WhenAskedForUnknownFeature()
2929
features.Set<IThing>(thing);
3030

3131
// Assert
32-
Assert.Throws<InvalidOperationException>(() => features.GetRequired<object>());
32+
Assert.Throws<InvalidOperationException>(features.GetRequired<object>);
3333
}
3434
}

src/HotChocolate/Core/test/StarWars/Resolvers/SharedResolvers.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ public IEnumerable<ICharacter> GetCharacter(
2828
return null;
2929
}
3030
return character.Friends
31-
.Select(t => repository.GetCharacter(t))
31+
.Select(repository.GetCharacter)
3232
.OfType<Human>()
3333
.FirstOrDefault();
3434
}

src/HotChocolate/Core/test/Subscriptions.Postgres.Tests/AsyncAutoResetEventTests.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ public void Set_Should_Throw_When_Disposed()
2525
autoResetEvent.Dispose();
2626

2727
// Act & Assert
28-
Assert.Throws<ObjectDisposedException>(() => autoResetEvent.Set());
28+
Assert.Throws<ObjectDisposedException>(autoResetEvent.Set);
2929
}
3030

3131
[Fact]

src/HotChocolate/Core/test/Subscriptions.Postgres.Tests/AsyncTaskDispatcherTests.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public async Task Dispatch_Should_Throw_When_CalledAfterDispose()
3838
await asyncEventHandler.DisposeAsync();
3939

4040
// Assert
41-
Assert.Throws<ObjectDisposedException>(() => asyncEventHandler.Dispatch());
41+
Assert.Throws<ObjectDisposedException>(asyncEventHandler.Dispatch);
4242
}
4343

4444
[Fact]

src/HotChocolate/Core/test/Subscriptions.Postgres.Tests/PostgresChannelTests.cs

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public async Task Subscribe_Should_ReceiveMessage_When_MessageIsSent()
3838
await channel.EnsureInitialized(CancellationToken.None);
3939

4040
var receivedMessages = new List<string>();
41-
var listener = new PostgresChannelObserver(topicName, e => receivedMessages.Add(e));
41+
var listener = new PostgresChannelObserver(topicName, receivedMessages.Add);
4242

4343
// Act
4444
channel.Subscribe(listener);
@@ -83,7 +83,7 @@ public async Task Subscribe_Should_ReceiveManySequential_Messages()
8383
await channel.EnsureInitialized(CancellationToken.None);
8484

8585
var receivedMessages = new ConcurrentBag<string>();
86-
var listener = new PostgresChannelObserver(topicName, e => receivedMessages.Add(e));
86+
var listener = new PostgresChannelObserver(topicName, receivedMessages.Add);
8787

8888
// Act
8989
channel.Subscribe(listener);
@@ -113,7 +113,7 @@ public async Task Subscribe_Should_ReceiveManyConcurrentMessages_From_ManyConnec
113113
await channel.EnsureInitialized(CancellationToken.None);
114114

115115
var receivedMessages = new ConcurrentBag<string>();
116-
var listener = new PostgresChannelObserver(topicName, e => receivedMessages.Add(e));
116+
var listener = new PostgresChannelObserver(topicName, receivedMessages.Add);
117117

118118
// Act
119119
channel.Subscribe(listener);
@@ -145,7 +145,7 @@ public async Task Subscribe_Should_ReceiveManyConcurrentMessages_From_SinlgeConn
145145
await channel.EnsureInitialized(CancellationToken.None);
146146

147147
var receivedMessages = new ConcurrentBag<string>();
148-
var listener = new PostgresChannelObserver(topicName, e => receivedMessages.Add(e));
148+
var listener = new PostgresChannelObserver(topicName, receivedMessages.Add);
149149

150150
// Act
151151
channel.Subscribe(listener);
@@ -177,7 +177,7 @@ public async Task SendAsync_Should_SendAndReceive()
177177
await channel.EnsureInitialized(CancellationToken.None);
178178

179179
var receivedMessages = new ConcurrentBag<string>();
180-
var listener = new PostgresChannelObserver(topicName, e => receivedMessages.Add(e));
180+
var listener = new PostgresChannelObserver(topicName, receivedMessages.Add);
181181
channel.Subscribe(listener);
182182

183183
// Act
@@ -201,7 +201,7 @@ public async Task SendAsync_Should_SendAllMessages_When_CalledConcurrently()
201201
await channel.EnsureInitialized(CancellationToken.None);
202202

203203
var receivedMessages = new ConcurrentBag<string>();
204-
var listener = new PostgresChannelObserver(topicName, e => receivedMessages.Add(e));
204+
var listener = new PostgresChannelObserver(topicName, receivedMessages.Add);
205205
channel.Subscribe(listener);
206206

207207
// Act
@@ -235,7 +235,7 @@ public async Task Subscribe_Should_AllowForManySubscribers()
235235

236236
for (var i = 0; i < 100; i++)
237237
{
238-
channel.Subscribe(new PostgresChannelObserver(topicName, e => receivedMessages.Add(e)));
238+
channel.Subscribe(new PostgresChannelObserver(topicName, receivedMessages.Add));
239239
}
240240

241241
// Act
@@ -259,7 +259,7 @@ public async Task Usubscribe_Should_StopListeningToMessages()
259259

260260
var receivedMessages = new ConcurrentBag<string>();
261261
var disposable =
262-
channel.Subscribe(new PostgresChannelObserver(topicName, e => receivedMessages.Add(e)));
262+
channel.Subscribe(new PostgresChannelObserver(topicName, receivedMessages.Add));
263263

264264
using var testChannel = new TestChannel(SyncConnectionFactory, _channelName);
265265
await testChannel.SendMessageAsync("aaaaaaaaaaaaaaaaaaaaaaaa:dGVzdA==:foobar");
@@ -303,7 +303,7 @@ public async Task Observable_Should_StayIntact_When_ReconnectAfterConnectionDrop
303303
using var testChannel = new TestChannel(SyncConnectionFactory, _channelName);
304304

305305
var receivedMessages = new ConcurrentBag<string>();
306-
channel.Subscribe(new PostgresChannelObserver(topicName, e => receivedMessages.Add(e)));
306+
channel.Subscribe(new PostgresChannelObserver(topicName, receivedMessages.Add));
307307

308308
// Act
309309
SpinWait.SpinUntil(() => connection is not null, TimeSpan.FromSeconds(1));
@@ -362,7 +362,7 @@ public async Task Observable_Should_StayIntact_When_ReconnectAfterConnectionDrop
362362
using var testChannel = new TestChannel(SyncConnectionFactory, _channelName);
363363

364364
var receivedMessages = new ConcurrentBag<string>();
365-
channel.Subscribe(new PostgresChannelObserver(topicName, e => receivedMessages.Add(e)));
365+
channel.Subscribe(new PostgresChannelObserver(topicName, receivedMessages.Add));
366366

367367
// Act
368368
SpinWait.SpinUntil(() => connection is not null, TimeSpan.FromSeconds(1));

0 commit comments

Comments
 (0)