huahaofeng
/
aspnetcore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Remove casts where possible

This commit is contained in:
David Fowler 2016-11-02 22:17:03 -07:00
parent 7db1eb8f25
commit 0e690d636f
4 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Microsoft.AspNetCore.SignalR.Redis/RedisHubLifetimeManager.cs
View File

@ -127,7 +127,7 @@ namespace Microsoft.AspNetCore.SignalR.Redis
private Task SubscribeAsync(string channel, Connection connection) private Task SubscribeAsync(string channel, Connection connection)
{ {
var redisConnection = connection.Metadata.GetOrAdd("redis", k => var redisConnection = connection.Metadata.GetOrAdd("redis", _ =>
{ {
var logger = _loggerFactory.CreateLogger("REDIS_" + connection.ConnectionId); var logger = _loggerFactory.CreateLogger("REDIS_" + connection.ConnectionId);
// TODO: Async // TODO: Async

6
src/Microsoft.AspNetCore.SignalR/DefaultHubLifetimeManager.cs
View File

@ -19,7 +19,7 @@ namespace Microsoft.AspNetCore.SignalR
public override Task AddGroupAsync(Connection connection, string groupName) public override Task AddGroupAsync(Connection connection, string groupName)
{ {
var groups = connection.Metadata.GetOrAdd("groups", k => new HashSet<string>()); var groups = connection.Metadata.GetOrAdd("groups", _ => new HashSet<string>());
lock (groups) lock (groups)
{ {
@ -63,7 +63,7 @@ namespace Microsoft.AspNetCore.SignalR
continue; continue;
} }
var invocationAdapter = _registry.GetInvocationAdapter((string)connection.Metadata["formatType"]); var invocationAdapter = _registry.GetInvocationAdapter(connection.Metadata.Get<string>("formatType"));
tasks.Add(invocationAdapter.WriteInvocationDescriptorAsync(message, connection.Channel.GetStream())); tasks.Add(invocationAdapter.WriteInvocationDescriptorAsync(message, connection.Channel.GetStream()));
} }
@ -75,7 +75,7 @@ namespace Microsoft.AspNetCore.SignalR
{ {
var connection = _connections[connectionId]; var connection = _connections[connectionId];
var invocationAdapter = _registry.GetInvocationAdapter((string)connection.Metadata["formatType"]); var invocationAdapter = _registry.GetInvocationAdapter(connection.Metadata.Get<string>("formatType"));
var message = new InvocationDescriptor var message = new InvocationDescriptor
{ {

2
src/Microsoft.AspNetCore.SignalR/RpcEndpoint.cs
View File

@ -36,7 +36,7 @@ namespace Microsoft.AspNetCore.SignalR
await Task.Yield(); await Task.Yield();
var stream = connection.Channel.GetStream(); var stream = connection.Channel.GetStream();
var invocationAdapter = _registry.GetInvocationAdapter((string)connection.Metadata["formatType"]); var invocationAdapter = _registry.GetInvocationAdapter(connection.Metadata.Get<string>("formatType"));
while (true) while (true)
{ {

2
src/Microsoft.AspNetCore.Sockets/HttpConnectionDispatcher.cs
View File

@ -116,7 +116,7 @@ namespace Microsoft.AspNetCore.Sockets
else else
{ {
// Get the endpoint task from connection state // Get the endpoint task from connection state
endpointTask = (Task)state.Connection.Metadata["endpoint"]; endpointTask = state.Connection.Metadata.Get<Task>("endpoint");
} }
var resultTask = await Task.WhenAny(endpointTask, transportTask); var resultTask = await Task.WhenAny(endpointTask, transportTask);