6 writes to Protocol
Microsoft.AspNetCore.SignalR.Core (1)
HubConnectionContext.cs (1)
543Protocol = protocolResolver.GetProtocol(handshakeRequestMessage.Protocol, supportedProtocols)!;
Microsoft.AspNetCore.SignalR.Microbenchmarks (3)
BroadcastBenchmark.cs (1)
51hubConnection.Protocol = protocol;
DefaultHubDispatcherBenchmark.cs (1)
52_connectionContext.Protocol = new FakeHubProtocol();
DefaultHubLifetimeManagerBenchmark.cs (1)
57hubConnectionContext.Protocol = jsonHubProtocol;
Microsoft.AspNetCore.SignalR.Specification.Tests (1)
src\SignalR\common\testassets\Tests.Utils\HubConnectionContextUtils.cs (1)
26Protocol = protocol ?? new JsonHubProtocol(),
Microsoft.AspNetCore.SignalR.Tests.Utils (1)
HubConnectionContextUtils.cs (1)
26Protocol = protocol ?? new JsonHubProtocol(),
15 references to Protocol
Microsoft.AspNetCore.SignalR.Core (13)
HubConnectionContext.cs (12)
280Protocol.WriteMessage(message, _connectionContext.Transport.Output); 308var buffer = message.GetSerializedMessage(Protocol); 442_connectionContext.Transport.Output.Write(HandshakeProtocol.GetSuccessfulHandshake(Protocol)); 544if (Protocol == null) 552if (!Protocol.IsVersionSupported(handshakeRequestMessage.Version)) 566if ((transferFormatFeature.SupportedFormats & Protocol.TransferFormat) == 0) 569await WriteHandshakeResponseAsync(new HandshakeResponseMessage($"Cannot use the '{Protocol.Name}' protocol on the current transport. The transport does not support '{Protocol.TransferFormat}' transfer format.")); 573transferFormatFeature.ActiveFormat = Protocol.TransferFormat; 576_cachedPingMessage = Protocol.GetMessageBytes(PingMessage.Instance); 598_messageBuffer = new MessageBuffer(_connectionContext, Protocol, _statefulReconnectBufferSize, _logger, _timeProvider); 604Log.HandshakeComplete(_logger, Protocol.Name);
HubConnectionHandler.cs (1)
266var protocol = connection.Protocol;
Microsoft.AspNetCore.SignalR.StackExchangeRedis (2)
RedisHubLifetimeManager.cs (2)
545var protocolName = connection.Protocol.Name; 554connection.Protocol.WriteMessage(completionMessage, memoryBufferWriter);