6 writes to Protocol
Microsoft.AspNetCore.SignalR.Core (1)
HubConnectionContext.cs (1)
585Protocol = 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)
303Protocol.WriteMessage(message, _connectionContext.Transport.Output); 341var buffer = message.GetSerializedMessage(Protocol); 484_connectionContext.Transport.Output.Write(HandshakeProtocol.GetSuccessfulHandshake(Protocol)); 586if (Protocol == null) 594if (!Protocol.IsVersionSupported(handshakeRequestMessage.Version)) 608if ((transferFormatFeature.SupportedFormats & Protocol.TransferFormat) == 0) 611await WriteHandshakeResponseAsync(new HandshakeResponseMessage($"Cannot use the '{Protocol.Name}' protocol on the current transport. The transport does not support '{Protocol.TransferFormat}' transfer format.")); 615transferFormatFeature.ActiveFormat = Protocol.TransferFormat; 618_cachedPingMessage = Protocol.GetMessageBytes(PingMessage.Instance); 640_messageBuffer = new MessageBuffer(_connectionContext, Protocol, _statefulReconnectBufferSize, _logger, _timeProvider); 646Log.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);