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

Subscribe in parallel

This commit is contained in:
David Fowler 2016-11-02 02:46:52 -07:00
parent 377711f68c
commit f41bcb9b2d
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -89,11 +89,13 @@ namespace Microsoft.AspNetCore.SignalR.Redis
}
}
public override async Task OnConnectedAsync(Connection connection)
public override Task OnConnectedAsync(Connection connection)
{
await SubscribeAsync(typeof(THub).Name, connection);
await SubscribeAsync(typeof(THub).Name + "." + connection.ConnectionId, connection);
await SubscribeAsync(typeof(THub).Name + "." + connection.User.Identity.Name, connection);
var task1 = SubscribeAsync(typeof(THub).Name, connection);
var task2 = SubscribeAsync(typeof(THub).Name + "." + connection.ConnectionId, connection);
var task3 = SubscribeAsync(typeof(THub).Name + "." + connection.User.Identity.Name, connection);
return Task.WhenAll(task2, task2, task3);
}
public override Task OnDisconnectedAsync(Connection connection)