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

Remove params from HubLifetimeManager

This commit is contained in:
David Fowler 2016-11-04 00:37:04 -07:00
parent 23eb8aa7bd
commit 6ccc8d6195
3 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -53,7 +53,7 @@ namespace Microsoft.AspNetCore.SignalR.Redis
}); });
} }
public override Task InvokeAllAsync(string methodName, params object[] args) public override Task InvokeAllAsync(string methodName, object[] args)
{ {
var message = new InvocationDescriptor var message = new InvocationDescriptor
{ {
@ -64,7 +64,7 @@ namespace Microsoft.AspNetCore.SignalR.Redis
return PublishAsync(typeof(THub).FullName, message); return PublishAsync(typeof(THub).FullName, message);
} }
public override Task InvokeConnectionAsync(string connectionId, string methodName, params object[] args) public override Task InvokeConnectionAsync(string connectionId, string methodName, object[] args)
{ {
var message = new InvocationDescriptor var message = new InvocationDescriptor
{ {
@ -75,7 +75,7 @@ namespace Microsoft.AspNetCore.SignalR.Redis
return PublishAsync(typeof(THub).FullName + "." + connectionId, message); return PublishAsync(typeof(THub).FullName + "." + connectionId, message);
} }
public override Task InvokeGroupAsync(string groupName, string methodName, params object[] args) public override Task InvokeGroupAsync(string groupName, string methodName, object[] args)
{ {
var message = new InvocationDescriptor var message = new InvocationDescriptor
{ {
@ -86,7 +86,7 @@ namespace Microsoft.AspNetCore.SignalR.Redis
return PublishAsync(typeof(THub).FullName + "." + groupName, message); return PublishAsync(typeof(THub).FullName + "." + groupName, message);
} }
public override Task InvokeUserAsync(string userId, string methodName, params object[] args) public override Task InvokeUserAsync(string userId, string methodName, object[] args)
{ {
var message = new InvocationDescriptor var message = new InvocationDescriptor
{ {

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

@ -41,7 +41,7 @@ namespace Microsoft.AspNetCore.SignalR
return Task.CompletedTask; return Task.CompletedTask;
} }
public override Task InvokeAllAsync(string methodName, params object[] args) public override Task InvokeAllAsync(string methodName, object[] args)
{ {
return InvokeAllWhere(methodName, args, c => true); return InvokeAllWhere(methodName, args, c => true);
} }
@ -71,7 +71,7 @@ namespace Microsoft.AspNetCore.SignalR
return Task.WhenAll(tasks); return Task.WhenAll(tasks);
} }
public override Task InvokeConnectionAsync(string connectionId, string methodName, params object[] args) public override Task InvokeConnectionAsync(string connectionId, string methodName, object[] args)
{ {
var connection = _connections[connectionId]; var connection = _connections[connectionId];
@ -86,7 +86,7 @@ namespace Microsoft.AspNetCore.SignalR
return invocationAdapter.WriteInvocationDescriptorAsync(message, connection.Channel.GetStream()); return invocationAdapter.WriteInvocationDescriptorAsync(message, connection.Channel.GetStream());
} }
public override Task InvokeGroupAsync(string groupName, string methodName, params object[] args) public override Task InvokeGroupAsync(string groupName, string methodName, object[] args)
{ {
return InvokeAllWhere(methodName, args, connection => return InvokeAllWhere(methodName, args, connection =>
{ {
@ -95,7 +95,7 @@ namespace Microsoft.AspNetCore.SignalR
}); });
} }
public override Task InvokeUserAsync(string userId, string methodName, params object[] args) public override Task InvokeUserAsync(string userId, string methodName, object[] args)
{ {
return InvokeAllWhere(methodName, args, connection => return InvokeAllWhere(methodName, args, connection =>
{ {

8
src/Microsoft.AspNetCore.SignalR/HubLifetimeManager.cs
View File

@ -9,13 +9,13 @@ namespace Microsoft.AspNetCore.SignalR
public abstract Task OnDisconnectedAsync(Connection connection); public abstract Task OnDisconnectedAsync(Connection connection);
public abstract Task InvokeAllAsync(string methodName, params object[] args); public abstract Task InvokeAllAsync(string methodName, object[] args);
public abstract Task InvokeConnectionAsync(string connectionId, string methodName, params object[] args); public abstract Task InvokeConnectionAsync(string connectionId, string methodName, object[] args);
public abstract Task InvokeGroupAsync(string groupName, string methodName, params object[] args); public abstract Task InvokeGroupAsync(string groupName, string methodName, object[] args);
public abstract Task InvokeUserAsync(string userId, string methodName, params object[] args); public abstract Task InvokeUserAsync(string userId, string methodName, object[] args);
public abstract Task AddGroupAsync(Connection connection, string groupName); public abstract Task AddGroupAsync(Connection connection, string groupName);