1 write to _bus
Microsoft.AspNetCore.SignalR.StackExchangeRedis (1)
RedisHubLifetimeManager.cs (1)
759_bus = _redisServerConnection.GetSubscriber();
13 references to _bus
Microsoft.AspNetCore.SignalR.StackExchangeRedis (13)
RedisHubLifetimeManager.cs (13)
118if (_bus is null) 127tasks.Add(_bus.UnsubscribeAsync(RedisChannel.Literal(connectionChannel))); 299return await _bus!.PublishAsync(RedisChannel.Literal(channel), payload); 332return lifetimeManager._bus!.UnsubscribeAsync(RedisChannel.Literal(channelName)); 365return lifetimeManager._bus!.UnsubscribeAsync(RedisChannel.Literal(channelName)); 374_bus?.UnsubscribeAll(); 452var channel = await _bus!.SubscribeAsync(RedisChannel.Literal(_channels.All)); 482var channel = await _bus!.SubscribeAsync(RedisChannel.Literal(_channels.GroupManagement)); 519var channel = await _bus!.SubscribeAsync(RedisChannel.Literal(_channels.Ack(_serverName))); 533var channel = await _bus!.SubscribeAsync(RedisChannel.Literal(connectionChannel)); 590var channel = await _bus!.SubscribeAsync(RedisChannel.Literal(channelName)); 616var channel = await _bus!.SubscribeAsync(RedisChannel.Literal(groupChannel)); 645var channel = await _bus!.SubscribeAsync(RedisChannel.Literal(_channels.ReturnResults));