2 instantiations of RedisProtocol
Microsoft.AspNetCore.SignalR.StackExchangeRedis (2)
RedisHubLifetimeManager.cs (2)
78_protocol = new RedisProtocol(new DefaultHubMessageSerializer(hubProtocolResolver, globalHubOptions.Value.SupportedProtocols, hubOptions.Value.SupportedProtocols)); 83_protocol = new RedisProtocol(new DefaultHubMessageSerializer(hubProtocolResolver, supportedProtocols, null));
12 references to RedisProtocol
Microsoft.AspNetCore.SignalR.StackExchangeRedis (12)
RedisHubLifetimeManager.cs (12)
16using RedisProtocol = Microsoft.AspNetCore.SignalR.StackExchangeRedis.Internal.RedisProtocol; // to disambiguate from StackExchange.Redis.RedisProtocol 35private readonly RedisProtocol _protocol; 351var message = RedisProtocol.WriteGroupCommand(new RedisGroupCommand(id, _serverName, action, groupName, connectionId)); 459var invocation = RedisProtocol.ReadInvocation(channelMessage.Message); 487var groupMessage = RedisProtocol.ReadGroupCommand(channelMessage.Message); 507await PublishAsync(_channels.Ack(groupMessage.ServerName), RedisProtocol.WriteAck(groupMessage.Id)); 522var ackId = RedisProtocol.ReadAck(channelMessage.Message); 536var invocation = RedisProtocol.ReadInvocation(channelMessage.Message); 555message = RedisProtocol.WriteCompletionMessage(memoryBufferWriter, protocolName); 595var invocation = RedisProtocol.ReadInvocation(channelMessage.Message); 621var invocation = RedisProtocol.ReadInvocation(channelMessage.Message); 648var completion = RedisProtocol.ReadCompletion(channelMessage.Message);