10 instantiations of RedisProtocol
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
RedisProtocolBenchmark.cs (1)
34_protocol = new RedisProtocol(new DefaultHubMessageSerializer(resolver, new List<string>() { "protocol1", "protocol2" }, hubSupportedProtocols: null));
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));
Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (7)
RedisProtocolTests.cs (7)
38var protocol = new RedisProtocol(CreateHubMessageSerializer(new List<IHubProtocol>())); 50var protocol = new RedisProtocol(CreateHubMessageSerializer(new List<IHubProtocol>())); 70var protocol = new RedisProtocol(CreateHubMessageSerializer(new List<IHubProtocol>())); 86var protocol = new RedisProtocol(CreateHubMessageSerializer(new List<IHubProtocol>())); 146var protocol = new RedisProtocol(CreateHubMessageSerializer(hubProtocols.Cast<IHubProtocol>().ToList())); 177var protocol = new RedisProtocol(CreateHubMessageSerializer(new List<IHubProtocol>() { new DummyHubProtocol("p1"), new DummyHubProtocol("p2") })); 193var protocol = new RedisProtocol(hubMessageSerializer);
36 references to RedisProtocol
Microsoft.AspNetCore.SignalR.Microbenchmarks (10)
RedisProtocolBenchmark.cs (10)
16private RedisProtocol _protocol; 45_writtenAck = RedisProtocol.WriteAck(42); 46_writtenGroupCommand = RedisProtocol.WriteGroupCommand(_groupCommand); 55RedisProtocol.WriteAck(42); 61RedisProtocol.WriteGroupCommand(_groupCommand); 85RedisProtocol.ReadAck(_writtenAck); 91RedisProtocol.ReadGroupCommand(_writtenGroupCommand); 97RedisProtocol.ReadInvocation(_writtenInvocationNoExclusions); 103RedisProtocol.ReadInvocation(_writtenInvocationSmallExclusions); 109RedisProtocol.ReadInvocation(_writtenInvocationLargeExclusions);
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);
Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (14)
RedisProtocolTests.cs (14)
38var protocol = new RedisProtocol(CreateHubMessageSerializer(new List<IHubProtocol>())); 40var decoded = RedisProtocol.ReadAck(testData.Encoded); 50var protocol = new RedisProtocol(CreateHubMessageSerializer(new List<IHubProtocol>())); 52var encoded = RedisProtocol.WriteAck(testData.Decoded); 70var protocol = new RedisProtocol(CreateHubMessageSerializer(new List<IHubProtocol>())); 72var decoded = RedisProtocol.ReadGroupCommand(testData.Encoded); 86var protocol = new RedisProtocol(CreateHubMessageSerializer(new List<IHubProtocol>())); 88var encoded = RedisProtocol.WriteGroupCommand(testData.Decoded); 146var protocol = new RedisProtocol(CreateHubMessageSerializer(hubProtocols.Cast<IHubProtocol>().ToList())); 150var decoded = RedisProtocol.ReadInvocation(testData.Encoded); 177var protocol = new RedisProtocol(CreateHubMessageSerializer(new List<IHubProtocol>() { new DummyHubProtocol("p1"), new DummyHubProtocol("p2") })); 193var protocol = new RedisProtocol(hubMessageSerializer); 256var completionMessage = RedisProtocol.ReadCompletion(testData.Encoded); 271var encoded = RedisProtocol.WriteCompletionMessage(writer, testData.Decoded.ProtocolName);