6 writes to Protocol
Microsoft.AspNetCore.SignalR.Core (1)
HubConnectionContext.cs (1)
580Protocol = 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)
298Protocol.WriteMessage(message, _connectionContext.Transport.Output); 336var buffer = message.GetSerializedMessage(Protocol); 479_connectionContext.Transport.Output.Write(HandshakeProtocol.GetSuccessfulHandshake(Protocol)); 581if (Protocol == null) 589if (!Protocol.IsVersionSupported(handshakeRequestMessage.Version)) 603if ((transferFormatFeature.SupportedFormats & Protocol.TransferFormat) == 0) 606await WriteHandshakeResponseAsync(new HandshakeResponseMessage($"Cannot use the '{Protocol.Name}' protocol on the current transport. The transport does not support '{Protocol.TransferFormat}' transfer format.")); 610transferFormatFeature.ActiveFormat = Protocol.TransferFormat; 613_cachedPingMessage = Protocol.GetMessageBytes(PingMessage.Instance); 635_messageBuffer = new MessageBuffer(_connectionContext, Protocol, _statefulReconnectBufferSize, _logger, _timeProvider); 641Log.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);