Skip to content
This repository was archived by the owner on Dec 18, 2018. It is now read-only.

Commit f803e6d

Browse files
committed
fixed test hang
1 parent 1a444a7 commit f803e6d

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/Microsoft.AspNetCore.SignalR.Redis/RedisHubLifetimeManager.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -190,6 +190,7 @@ public override Task InvokeGroupAsync(string groupName, string methodName, objec
190190
throw new ArgumentNullException(nameof(groupName));
191191
}
192192

193+
//var message = new InvocationMessage(GetInvocationId(), nonBlocking: true, target: methodName, argumentBindingException: null, arguments: args);
193194
var message = new RedisExcludeClientsMessage(GetInvocationId(), nonBlocking: true, target: methodName, excludedIds: null, arguments: args);
194195

195196
return PublishAsync(_channelNamePrefix + ".group." + groupName, message);
@@ -564,7 +565,7 @@ private Task SubscribeToGroup(string groupChannel, GroupData group)
564565
var tasks = new List<Task>();
565566
foreach (var groupConnection in group.Connections)
566567
{
567-
if (message.ExcludedIds.Contains(groupConnection.ConnectionId))
568+
if (message.ExcludedIds?.Contains(groupConnection.ConnectionId) == true)
568569
{
569570
continue;
570571
}

0 commit comments

Comments
 (0)