6 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.Client.Core (1)
HubConnection.cs (1)
969await SendWithLock(connectionState, new StreamItemMessage(streamId, item), tokenSource.Token).ConfigureAwait(false);
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);
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (1)
Protocol\MessagePackHubProtocolWorker.cs (1)
156return ApplyHeaders(headers, new StreamItemMessage(invocationId, value));
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (1)
Protocol\NewtonsoftJsonHubProtocol.cs (1)
763return new StreamItemMessage(invocationId, item);
18 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.Client.Core (2)
HubConnection.cs (2)
1329case StreamItemMessage streamItem: 1458private async Task DispatchInvocationStreamItemAsync(StreamItemMessage streamItem, InvocationRequest irq)
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)
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (2)
Protocol\MessagePackHubProtocolWorker.cs (2)
397case StreamItemMessage streamItemMessage: 482private void WriteStreamingItemMessage(StreamItemMessage message, ref MessagePackWriter writer)
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (2)
Protocol\NewtonsoftJsonHubProtocol.cs (2)
533case StreamItemMessage m: 622private void WriteStreamItemMessage(StreamItemMessage message, JsonTextWriter writer)
Microsoft.AspNetCore.SignalR.Specification.Tests (2)
src\aspnetcore\src\SignalR\common\testassets\Tests.Utils\TestClient.cs (2)
136case StreamItemMessage _: 169case StreamItemMessage: