1 write to _channels
Microsoft.AspNetCore.SignalR.StackExchangeRedis (1)
RedisHubLifetimeManager.cs (1)
75_channels = new RedisChannels(typeof(THub).FullName!, _serverName);
25 references to _channels
Microsoft.AspNetCore.SignalR.StackExchangeRedis (25)
RedisHubLifetimeManager.cs (25)
123var connectionChannel = _channels.Connection(connection.ConnectionId); 156return PublishAsync(_channels.All, message); 163return PublishAsync(_channels.All, message); 180return PublishAsync(_channels.Connection(connectionId), message); 189return PublishAsync(_channels.Group(groupName), message); 198return PublishAsync(_channels.Group(groupName), message); 205return PublishAsync(_channels.User(userId), message); 250publishTasks.Add(PublishAsync(_channels.Connection(connectionId), payload)); 267publishTasks.Add(PublishAsync(_channels.Group(groupName), payload)); 285publishTasks.Add(PublishAsync(_channels.User(userId), payload)); 316var groupChannel = _channels.Group(groupName); 326var groupChannel = _channels.Group(groupName); 352await PublishAsync(_channels.GroupManagement, message); 359var userChannel = _channels.User(connection.UserIdentifier!); 399var messageBytes = _protocol.WriteInvocation(methodName, args, invocationId, returnChannel: _channels.ReturnResults); 400var received = await PublishAsync(_channels.Connection(connectionId), messageBytes); 451RedisLog.Subscribing(_logger, _channels.All); 452var channel = await _bus!.SubscribeAsync(RedisChannel.Literal(_channels.All)); 457RedisLog.ReceivedFromChannel(_logger, _channels.All); 482var channel = await _bus!.SubscribeAsync(RedisChannel.Literal(_channels.GroupManagement)); 507await PublishAsync(_channels.Ack(groupMessage.ServerName), RedisProtocol.WriteAck(groupMessage.Id)); 519var channel = await _bus!.SubscribeAsync(RedisChannel.Literal(_channels.Ack(_serverName))); 530var connectionChannel = _channels.Connection(connection.ConnectionId); 585var userChannel = _channels.User(connection.UserIdentifier!); 645var channel = await _bus!.SubscribeAsync(RedisChannel.Literal(_channels.ReturnResults));