15 references to StreamInvocationMessage
Microsoft.AspNetCore.Components.Server (1)
src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (1)
136return ApplyHeaders(headers, new StreamInvocationMessage(invocationId, target, arguments, streams));
Microsoft.AspNetCore.Components.Server.Tests (3)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\MessagePackHubProtocolTestBase.cs (3)
155message: new StreamInvocationMessage("xyz", "method", Array.Empty<object>(), new string[] { "__test_id__" }), 159message: new StreamInvocationMessage("xyz", "method", new object[] { 42 }, new string[] { "__test_id__" }), 429new MessageSizeTestData("StreamInvocationMessage_WithStreamId", new StreamInvocationMessage("1", "target", Array.Empty<object>(), new [] { "2" }), 17),
Microsoft.AspNetCore.SignalR.Client.Core (1)
HubConnection.cs (1)
1164var invocationMessage = new StreamInvocationMessage(irq.InvocationId, methodName, args, streams);
Microsoft.AspNetCore.SignalR.Common.Tests (5)
Internal\Protocol\JsonHubProtocolTestsBase.cs (2)
78new JsonProtocolTestData("StreamInvocationMessage_HasStreamArgument", new StreamInvocationMessage("123", "Target", Array.Empty<object>(), new string[] { "__test_id__" }), true, true, "{\"type\":4,\"invocationId\":\"123\",\"target\":\"Target\",\"arguments\":[],\"streamIds\":[\"__test_id__\"]}"), 377new MessageSizeTestData("StreamInvocationMessage_WithStreamId", new StreamInvocationMessage("1", "target", Array.Empty<object>(), new [] { "2" }), 81),
Internal\Protocol\MessagePackHubProtocolTestBase.cs (3)
155message: new StreamInvocationMessage("xyz", "method", Array.Empty<object>(), new string[] { "__test_id__" }), 159message: new StreamInvocationMessage("xyz", "method", new object[] { 42 }, new string[] { "__test_id__" }), 429new MessageSizeTestData("StreamInvocationMessage_WithStreamId", new StreamInvocationMessage("1", "target", Array.Empty<object>(), new [] { "2" }), 17),
Microsoft.AspNetCore.SignalR.Protocols.Json (1)
Protocol\JsonHubProtocol.cs (1)
793return new StreamInvocationMessage(invocationId, target, arguments, streamIds);
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (1)
Protocol\MessagePackHubProtocolWorker.cs (1)
136return ApplyHeaders(headers, new StreamInvocationMessage(invocationId, target, arguments, streams));
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (1)
Protocol\NewtonsoftJsonHubProtocol.cs (1)
785return new StreamInvocationMessage(invocationId, target, arguments, streamIds);
Microsoft.AspNetCore.SignalR.Specification.Tests (1)
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (1)
223return SendHubMessageAsync(new StreamInvocationMessage(invocationId, methodName, args, streamIds) { Headers = headers });
Microsoft.AspNetCore.SignalR.Tests.Utils (1)
TestClient.cs (1)
223return SendHubMessageAsync(new StreamInvocationMessage(invocationId, methodName, args, streamIds) { Headers = headers });