1 write to StreamIds
Microsoft.AspNetCore.SignalR.Common (1)
Protocol\HubMethodInvocationMessage.cs (1)
40StreamIds = streamIds;
28 references to StreamIds
Microsoft.AspNetCore.Components.Server (2)
src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (2)
454WriteStreamIds(message.StreamIds, ref writer); 479WriteStreamIds(message.StreamIds, ref writer);
Microsoft.AspNetCore.Components.Server.Tests (4)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\TestHubMessageEqualityComparer.cs (4)
73&& StringArrayEqual(x.StreamIds, y.StreamIds); 82&& StringArrayEqual(x.StreamIds, y.StreamIds);
Microsoft.AspNetCore.SignalR.Common (6)
Protocol\HubMethodInvocationMessage.cs (6)
113streamIds = string.Join(", ", StreamIds != null ? StreamIds.Select(id => id?.ToString()) : Array.Empty<string>()); 120return $"InvocationMessage {{ {nameof(InvocationId)}: \"{InvocationId}\", {nameof(Target)}: \"{Target}\", {nameof(Arguments)}: [ {args} ], {nameof(StreamIds)}: [ {streamIds} ] }}"; 168streamIds = string.Join(", ", StreamIds != null ? StreamIds.Select(id => id?.ToString()) : Array.Empty<string>()); 175return $"StreamInvocation {{ {nameof(InvocationId)}: \"{InvocationId}\", {nameof(Target)}: \"{Target}\", {nameof(Arguments)}: [ {args} ], {nameof(StreamIds)}: [ {streamIds} ] }}";
Microsoft.AspNetCore.SignalR.Common.Tests (5)
Internal\Protocol\JsonHubProtocolTestsBase.cs (1)
209Assert.Same(Array.Empty<string>(), (message as InvocationMessage).StreamIds);
Internal\Protocol\TestHubMessageEqualityComparer.cs (4)
73&& StringArrayEqual(x.StreamIds, y.StreamIds); 82&& StringArrayEqual(x.StreamIds, y.StreamIds);
Microsoft.AspNetCore.SignalR.Core (5)
Internal\DefaultHubDispatcher.cs (5)
348var clientStreamLength = hubMethodInvocationMessage.StreamIds?.Length ?? 0; 495if (hubMessage.StreamIds != null) 497foreach (var stream in hubMessage.StreamIds) 750Log.StartingParameterStream(_logger, hubMethodInvocationMessage.StreamIds![streamPointer]); 752arguments[parameterPointer] = connection.StreamTracker.AddStream(hubMethodInvocationMessage.StreamIds[streamPointer],
Microsoft.AspNetCore.SignalR.Protocols.Json (2)
Protocol\JsonHubProtocol.cs (2)
647WriteStreamIds(message.StreamIds, writer); 657WriteStreamIds(message.StreamIds, writer);
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (2)
Protocol\MessagePackHubProtocolWorker.cs (2)
454WriteStreamIds(message.StreamIds, ref writer); 479WriteStreamIds(message.StreamIds, ref writer);
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (2)
Protocol\NewtonsoftJsonHubProtocol.cs (2)
637WriteStreamIds(message.StreamIds, writer); 648WriteStreamIds(message.StreamIds, writer);