@@ -564,7 +564,7 @@ private Task SubscribeToGroup(string groupChannel, GroupData group)
564564 var tasks = new List < Task > ( ) ;
565565 foreach ( var groupConnection in group . Connections )
566566 {
567- if ( message . ExcludedIds ? . Contains ( groupConnection . ConnectionId ) == true )
567+ if ( message . ExcludedIds . Contains ( groupConnection . ConnectionId ) )
568568 {
569569 continue ;
570570 }
@@ -606,17 +606,11 @@ public override void WriteLine(string value)
606606 private class RedisExcludeClientsMessage : InvocationMessage
607607 {
608608 public IReadOnlyList < string > ExcludedIds ;
609- public string GroupName ;
610609
611- public RedisExcludeClientsMessage ( string invocationId , bool nonBlocking , string target , IReadOnlyList < string > excludedIds , params object [ ] arguments ) :
612- this ( invocationId , nonBlocking , target , excludedIds , groupName : null , arguments : arguments )
613- { }
614-
615- public RedisExcludeClientsMessage ( string invocationId , bool nonBlocking , string target , IReadOnlyList < string > excludedIds , string groupName , params object [ ] arguments )
610+ public RedisExcludeClientsMessage ( string invocationId , bool nonBlocking , string target , IReadOnlyList < string > excludedIds , params object [ ] arguments )
616611 : base ( invocationId , nonBlocking , target , argumentBindingException : null , arguments : arguments )
617612 {
618613 ExcludedIds = excludedIds ;
619- GroupName = groupName ;
620614 }
621615 }
622616
0 commit comments