3 instantiations of StreamItemMessage
Microsoft.AspNetCore.Components.Server (1)
src\aspnetcore\src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (1)
156return ApplyHeaders(headers, new StreamItemMessage(invocationId, value));
Microsoft.AspNetCore.SignalR.Core (1)
Internal\DefaultHubDispatcher.cs (1)
559var streamItemMessage = new StreamItemMessage(invocationId, null);
Microsoft.AspNetCore.SignalR.Protocols.Json (1)
Protocol\JsonHubProtocol.cs (1)
770return new StreamItemMessage(invocationId, item);
10 references to StreamItemMessage
Microsoft.AspNetCore.Components.Server (2)
src\aspnetcore\src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (2)
397case StreamItemMessage streamItemMessage: 482private void WriteStreamingItemMessage(StreamItemMessage message, ref MessagePackWriter writer)
Microsoft.AspNetCore.SignalR.Common (1)
Protocol\StreamItemMessage.cs (1)
17/// Constructs a <see cref="StreamItemMessage"/>.
Microsoft.AspNetCore.SignalR.Core (5)
Internal\DefaultHubDispatcher.cs (3)
202case StreamItemMessage streamItem: 270private Task ProcessStreamItem(HubConnectionContext connection, StreamItemMessage message) 559var streamItemMessage = new StreamItemMessage(invocationId, null);
Internal\DefaultHubDispatcherLog.cs (1)
74public static void ReceivedStreamItem(ILogger logger, StreamItemMessage message)
StreamTracker.cs (1)
52public bool TryProcessItem(StreamItemMessage message, [NotNullWhen(true)] out Task? task)
Microsoft.AspNetCore.SignalR.Protocols.Json (2)
Protocol\JsonHubProtocol.cs (2)
536case StreamItemMessage m: 625private void WriteStreamItemMessage(StreamItemMessage message, Utf8JsonWriter writer)