108 instantiations of InvocationMessage
Microsoft.AspNetCore.Components.Server (1)
src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (1)
106return ApplyHeaders(headers, new InvocationMessage(invocationId, target, arguments, streams));
Microsoft.AspNetCore.Components.Server.Tests (11)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\MessagePackHubProtocolTestBase.cs (11)
65message: new InvocationMessage("xyz", "method", Array.Empty<object>()), 69message: new InvocationMessage("method", Array.Empty<object>()), 73message: new InvocationMessage("method", new object[] { 42 }), 77message: new InvocationMessage("method", new object[] { 42, "string" }), 81message: new InvocationMessage(null, "Target", Array.Empty<object>(), new string[] { "__test_id__" }), 85message: new InvocationMessage(null, "Target", new object[] { 42 }, new string[] { "__test_id__" }), 89message: new InvocationMessage(null, "Target", Array.Empty<object>(), new string[] { "__test_id__", "__test_id2__" }), 239var expectedMessage = new InvocationMessage("xyz", "method", Array.Empty<object>()); 414new MessageSizeTestData("InvocationMessage_WithoutInvocationId", new InvocationMessage("Target", new object[] { 1 }), 15), 415new MessageSizeTestData("InvocationMessage_WithInvocationId", new InvocationMessage("1", "Target", new object[] { 1 }), 16), 416new MessageSizeTestData("InvocationMessage_WithInvocationIdAndStreamId", new InvocationMessage("1", "Target", new object[] { 1 }, new string[] { "2" }), 18),
Microsoft.AspNetCore.SignalR.Client.Core (2)
HubConnection.cs (2)
1134var invocationMessage = new InvocationMessage(irq.InvocationId, methodName, args, streams); 1237var invocationMessage = new InvocationMessage(null, methodName, args, streamIds?.ToArray());
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (1)
VersionJsonHubProtocol.cs (1)
44message = new InvocationMessage("NewProtocolMethodServer", Array.Empty<object>());
Microsoft.AspNetCore.SignalR.Common.Tests (42)
Internal\Protocol\JsonHubProtocolTests.cs (4)
101var expectedMessage = new InvocationMessage("Method", new object[] { 1 }); 124JsonHubProtocol.WriteMessage(new InvocationMessage("method", new[] { todo }), writer); 212new JsonProtocolTestData("InvocationMessage_HasFloatArgument", new InvocationMessage(null, "Target", new object[] { 1, "Foo", 2.0f }), true, true, "{\"type\":1,\"target\":\"Target\",\"arguments\":[1,\"Foo\",2]}"), 213new JsonProtocolTestData("InvocationMessage_HasHeaders", AddHeaders(TestHeaders, new InvocationMessage("123", "Target", new object[] { 1, "Foo", 2.0f })), true, true, "{\"type\":1," + SerializedHeaders + ",\"invocationId\":\"123\",\"target\":\"Target\",\"arguments\":[1,\"Foo\",2]}"),
Internal\Protocol\JsonHubProtocolTestsBase.cs (20)
32new JsonProtocolTestData("InvocationMessage_HasInvocationId", new InvocationMessage("123", "Target", new object[] { 1, "Foo" }), true, true, "{\"type\":1,\"invocationId\":\"123\",\"target\":\"Target\",\"arguments\":[1,\"Foo\"]}"), 33new JsonProtocolTestData("InvocationMessage_HasBoolArgument", new InvocationMessage(null, "Target", new object[] { true }), true, true, "{\"type\":1,\"target\":\"Target\",\"arguments\":[true]}"), 34new JsonProtocolTestData("InvocationMessage_HasNullArgument", new InvocationMessage(null, "Target", new object[] { null }), true, true, "{\"type\":1,\"target\":\"Target\",\"arguments\":[null]}"), 35new JsonProtocolTestData("InvocationMessage_HasStreamArgument", new InvocationMessage(null, "Target", Array.Empty<object>(), new string[] { "__test_id__" }), true, true, "{\"type\":1,\"target\":\"Target\",\"arguments\":[],\"streamIds\":[\"__test_id__\"]}"), 36new JsonProtocolTestData("InvocationMessage_HasStreamAndNormalArgument", new InvocationMessage(null, "Target", new object[] { 42 }, new string[] { "__test_id__" }), true, true, "{\"type\":1,\"target\":\"Target\",\"arguments\":[42],\"streamIds\":[\"__test_id__\"]}"), 37new JsonProtocolTestData("InvocationMessage_HasMultipleStreams", new InvocationMessage(null, "Target", Array.Empty<object>(), new string[] { "__test_id__", "__test_id2__" }), true, true, "{\"type\":1,\"target\":\"Target\",\"arguments\":[],\"streamIds\":[\"__test_id__\",\"__test_id2__\"]}"), 38new JsonProtocolTestData("InvocationMessage_DateTimeOffsetArgument", new InvocationMessage("Method", new object[] { DateTimeOffset.Parse("2016-05-10T13:51:20+12:34", CultureInfo.InvariantCulture) }), true, true, "{\"type\":1,\"target\":\"Method\",\"arguments\":[\"2016-05-10T13:51:20+12:34\"]}"), 39new JsonProtocolTestData("InvocationMessage_StringIsoDateArgument", new InvocationMessage("Method", new object[] { "2016-05-10T13:51:20+12:34" }), true, true, "{\"type\":1,\"target\":\"Method\",\"arguments\":[\"2016-05-10T13:51:20+12:34\"]}"), 40new JsonProtocolTestData("InvocationMessage_HasNonAsciiArgument", new InvocationMessage("Method", new object[] { "מחרוזת כלשהי" }), true, true, "{\"type\":1,\"target\":\"Method\",\"arguments\":[\"מחרוזת כלשהי\"]}"), 41new JsonProtocolTestData("InvocationMessage_HasCustomArgumentWithNoCamelCase", new InvocationMessage(null, "Target", new object[] { new CustomObject() }), false, true, "{\"type\":1,\"target\":\"Target\",\"arguments\":[{\"StringProp\":\"SignalR!\",\"DoubleProp\":6.2831853071,\"IntProp\":42,\"DateTimeProp\":\"2017-04-11T00:00:00Z\",\"ByteArrProp\":\"AQID\"}]}"), 42new JsonProtocolTestData("InvocationMessage_HasCustomArgumentWithNullValueIgnore", new InvocationMessage(null, "Target", new object[] { new CustomObject() }), true, true, "{\"type\":1,\"target\":\"Target\",\"arguments\":[{\"stringProp\":\"SignalR!\",\"doubleProp\":6.2831853071,\"intProp\":42,\"dateTimeProp\":\"2017-04-11T00:00:00Z\",\"byteArrProp\":\"AQID\"}]}"), 43new JsonProtocolTestData("InvocationMessage_HasCustomArgumentWithNullValueIgnoreAndNoCamelCase", new InvocationMessage(null, "Target", new object[] { new CustomObject() }), false, false, "{\"type\":1,\"target\":\"Target\",\"arguments\":[{\"StringProp\":\"SignalR!\",\"DoubleProp\":6.2831853071,\"IntProp\":42,\"DateTimeProp\":\"2017-04-11T00:00:00Z\",\"NullProp\":null,\"ByteArrProp\":\"AQID\"}]}"), 44new JsonProtocolTestData("InvocationMessage_HasCustomArgumentWithNullValueInclude", new InvocationMessage(null, "Target", new object[] { new CustomObject() }), true, false, "{\"type\":1,\"target\":\"Target\",\"arguments\":[{\"stringProp\":\"SignalR!\",\"doubleProp\":6.2831853071,\"intProp\":42,\"dateTimeProp\":\"2017-04-11T00:00:00Z\",\"nullProp\":null,\"byteArrProp\":\"AQID\"}]}"), 102new JsonProtocolTestData("InvocationMessage_StringIsoDateArgumentFirst", new InvocationMessage("Method", new object[] { "2016-05-10T13:51:20+12:34" }), false, true, "{ \"arguments\": [\"2016-05-10T13:51:20+12:34\"], \"type\":1, \"target\": \"Method\" }"), 103new JsonProtocolTestData("InvocationMessage_DateTimeOffsetArgumentFirst", new InvocationMessage("Method", new object[] { DateTimeOffset.Parse("2016-05-10T13:51:20+12:34", CultureInfo.InvariantCulture) }), false, true, "{ \"arguments\": [\"2016-05-10T13:51:20+12:34\"], \"type\":1, \"target\": \"Method\" }"), 104new JsonProtocolTestData("InvocationMessage_IntegerArrayArgumentFirst", new InvocationMessage("Method", new object[] { 1, 2 }), false, true, "{ \"arguments\": [1,2], \"type\":1, \"target\": \"Method\" }"), 349JsonHubProtocol.WriteMessage(new InvocationMessage("123", "Target", new object[] { obj }), writer); 362new MessageSizeTestData("InvocationMessage_WithoutInvocationId", new InvocationMessage("Target", new object[] { 1 }), 45), 363new MessageSizeTestData("InvocationMessage_WithInvocationId", new InvocationMessage("1", "Target", new object[] { 1 }), 64), 364new MessageSizeTestData("InvocationMessage_WithInvocationIdAndStreamId", new InvocationMessage("1", "Target", new object[] { 1 }, new string[] { "2" }), 82),
Internal\Protocol\MessagePackHubProtocolTestBase.cs (11)
65message: new InvocationMessage("xyz", "method", Array.Empty<object>()), 69message: new InvocationMessage("method", Array.Empty<object>()), 73message: new InvocationMessage("method", new object[] { 42 }), 77message: new InvocationMessage("method", new object[] { 42, "string" }), 81message: new InvocationMessage(null, "Target", Array.Empty<object>(), new string[] { "__test_id__" }), 85message: new InvocationMessage(null, "Target", new object[] { 42 }, new string[] { "__test_id__" }), 89message: new InvocationMessage(null, "Target", Array.Empty<object>(), new string[] { "__test_id__", "__test_id2__" }), 239var expectedMessage = new InvocationMessage("xyz", "method", Array.Empty<object>()); 414new MessageSizeTestData("InvocationMessage_WithoutInvocationId", new InvocationMessage("Target", new object[] { 1 }), 15), 415new MessageSizeTestData("InvocationMessage_WithInvocationId", new InvocationMessage("1", "Target", new object[] { 1 }), 16), 416new MessageSizeTestData("InvocationMessage_WithInvocationIdAndStreamId", new InvocationMessage("1", "Target", new object[] { 1 }, new string[] { "2" }), 18),
Internal\Protocol\MessagePackHubProtocolTests.cs (5)
119message: new InvocationMessage("method", new object[] { null }), 123message: new InvocationMessage("method", new object[] { 42, TestEnum.One }), 127message: new InvocationMessage("method", new object[] { 42, "string", new CustomObject() }), 131message: new InvocationMessage("method", new object[] { new CustomObject(), new CustomObject() }), 135message: AddHeaders(TestHeaders, new InvocationMessage("method", new object[] { new CustomObject(), new CustomObject() })),
Internal\Protocol\NewtonsoftJsonHubProtocolTests.cs (2)
98new JsonProtocolTestData("InvocationMessage_HasFloatArgument", new InvocationMessage(null, "Target", new object[] { 1, "Foo", 2.0f }), true, true, "{\"type\":1,\"target\":\"Target\",\"arguments\":[1,\"Foo\",2.0]}"), 99new JsonProtocolTestData("InvocationMessage_HasHeaders", AddHeaders(TestHeaders, new InvocationMessage("123", "Target", new object[] { 1, "Foo", 2.0f })), true, true, "{\"type\":1," + SerializedHeaders + ",\"invocationId\":\"123\",\"target\":\"Target\",\"arguments\":[1,\"Foo\",2.0]}"),
Microsoft.AspNetCore.SignalR.Core (2)
DefaultHubLifetimeManager.cs (2)
282return new InvocationMessage(methodName, args); 358var message = new InvocationMessage(invocationId, methodName, args);
Microsoft.AspNetCore.SignalR.Microbenchmarks (18)
DefaultHubDispatcherBenchmark.cs (9)
215return _dispatcher.DispatchMessageAsync(_connectionContext, new InvocationMessage("123", "Invocation", Array.Empty<object>())); 221return _dispatcher.DispatchMessageAsync(_connectionContext, new InvocationMessage("123", "InvocationAsync", Array.Empty<object>())); 227return _dispatcher.DispatchMessageAsync(_connectionContext, new InvocationMessage("123", "InvocationReturnValue", Array.Empty<object>())); 233return _dispatcher.DispatchMessageAsync(_connectionContext, new InvocationMessage("123", "InvocationReturnAsync", Array.Empty<object>())); 239return _dispatcher.DispatchMessageAsync(_connectionContext, new InvocationMessage("123", "InvocationValueTaskAsync", Array.Empty<object>())); 344await _dispatcher.DispatchMessageAsync(_connectionContext, new InvocationMessage("123", nameof(TestHub.UploadStream), Array.Empty<object>(), streamIds: new string[] { "1" })); 355await _dispatcher.DispatchMessageAsync(_connectionContext, new InvocationMessage("123", nameof(TestHub.UploadStreamIAsynEnumerable), Array.Empty<object>(), streamIds: new string[] { "1" })); 366await _dispatcher.DispatchMessageAsync(_connectionContext, new InvocationMessage("123", nameof(TestHub.UploadStream), Array.Empty<object>(), streamIds: new string[] { "1" })); 380await _dispatcher.DispatchMessageAsync(_connectionContext, new InvocationMessage("123", nameof(TestHub.UploadStreamIAsynEnumerable), Array.Empty<object>(), streamIds: new string[] { "1" }));
HubConnectionReceiveBenchmark.cs (1)
75_invocationMessageBytes = hubProtocol.GetMessageBytes(new InvocationMessage(MethodName, arguments));
HubProtocolBenchmark.cs (4)
42_hubMessage = new InvocationMessage("Target", Array.Empty<object>()); 45_hubMessage = new InvocationMessage("Target", new object[] { 1, "Foo", 2.0f }); 48_hubMessage = new InvocationMessage("Target", new object[] { 1, "string", 2.0f, true, (byte)9, new byte[] { 5, 4, 3, 2, 1 }, 'c', 123456789101112L }); 51_hubMessage = new InvocationMessage("Target", new object[] { new string('F', 10240), new byte[10240] });
ServerSentEventsBenchmark.cs (4)
45hubMessage = new InvocationMessage("Target", Array.Empty<object>()); 48hubMessage = new InvocationMessage("Target", new object[] { 1, "Foo", 2.0f }); 51hubMessage = new InvocationMessage("Target", new object[] { 1, "string", 2.0f, true, (byte)9, new[] { 5, 4, 3, 2, 1 }, 'c', 123456789101112L }); 54hubMessage = new InvocationMessage("Target", new object[] { new string('F', 10240), new string('B', 10240) });
Microsoft.AspNetCore.SignalR.Protocols.Json (1)
Protocol\JsonHubProtocol.cs (1)
811return new InvocationMessage(invocationId, target, arguments, streamIds);
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (1)
Protocol\MessagePackHubProtocolWorker.cs (1)
106return ApplyHeaders(headers, new InvocationMessage(invocationId, target, arguments, streams));
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (1)
Protocol\NewtonsoftJsonHubProtocol.cs (1)
802return new InvocationMessage(invocationId, target, arguments, streamIds);
Microsoft.AspNetCore.SignalR.Specification.Tests (2)
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (2)
207return SendHubMessageAsync(new InvocationMessage(invocationId, methodName, args) { Headers = headers }); 228var message = new InvocationMessage(invocationId, methodName, args, streamIds);
Microsoft.AspNetCore.SignalR.StackExchangeRedis (3)
Internal\RedisProtocol.cs (1)
72WriteHubMessage(ref writer, new InvocationMessage(invocationId, methodName, args));
RedisHubLifetimeManager.cs (2)
176return connection.WriteAsync(new InvocationMessage(methodName, args), cancellationToken).AsTask(); 410var message = new InvocationMessage(invocationId, methodName, args);
Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (2)
DefaultHubMessageSerializerTests.cs (1)
135private static readonly InvocationMessage _testMessage = new InvocationMessage("target", Array.Empty<object>());
RedisProtocolTests.cs (1)
94private static readonly InvocationMessage _testMessage = new InvocationMessage("target", Array.Empty<object>());
Microsoft.AspNetCore.SignalR.Tests (19)
HubConnectionHandlerTests.ClientResult.cs (7)
25var invocationId = await client.SendHubMessageAsync(new InvocationMessage("1", nameof(MethodHub.GetClientResult), new object[] { 5 })).DefaultTimeout(); 58var invocationId = await client.SendHubMessageAsync(new InvocationMessage("1", nameof(MethodHub.GetClientResult), new object[] { 5 })).DefaultTimeout(); 208var invocationId = await client.SendHubMessageAsync(new InvocationMessage( 244_ = await client.SendHubMessageAsync(new InvocationMessage("1", nameof(MethodHub.BlockingMethod), Array.Empty<object>())).DefaultTimeout(); 247var invocationId = await client.SendHubMessageAsync(new InvocationMessage("2", nameof(MethodHub.GetClientResult), new object[] { 5 })).DefaultTimeout(); 248var invocationId2 = await client.SendHubMessageAsync(new InvocationMessage("3", nameof(MethodHub.GetClientResult), new object[] { 5 })).DefaultTimeout(); 249var invocationId3 = await client.SendHubMessageAsync(new InvocationMessage("4", nameof(MethodHub.GetClientResult), new object[] { 5 })).DefaultTimeout();
Internal\MessageBufferTests.cs (9)
54await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[100000] })), default); 92await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[40] })), default); 95var writeTask = messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[40] })), default); 292await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { 1 })), default); 409await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[10] })), default); 410await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[100] })), default).DefaultTimeout(); 411var writeTask = messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[100] })), default); 452await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[10] })), default); 453var writeTask = messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[100] })), default).DefaultTimeout();
SerializedHubMessageTests.cs (3)
18var invocation = new InvocationMessage("Foo", new object[0]); 32var invocation = new InvocationMessage("Foo", new object[0]); 56var invocation = new InvocationMessage("Foo", new object[0]);
Microsoft.AspNetCore.SignalR.Tests.Utils (2)
TestClient.cs (2)
207return SendHubMessageAsync(new InvocationMessage(invocationId, methodName, args) { Headers = headers }); 228var message = new InvocationMessage(invocationId, methodName, args, streamIds);
186 references to InvocationMessage
Microsoft.AspNetCore.Components.Server (2)
src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (2)
391case InvocationMessage invocationMessage: 425private void WriteInvocationMessage(InvocationMessage message, ref MessagePackWriter writer)
Microsoft.AspNetCore.Components.Server.Tests (6)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\MessagePackHubProtocolTestBase.cs (1)
239var expectedMessage = new InvocationMessage("xyz", "method", Array.Empty<object>());
src\SignalR\common\SignalR.Common\test\Internal\Protocol\TestBinder.cs (1)
23case InvocationMessage i:
src\SignalR\common\SignalR.Common\test\Internal\Protocol\TestHubMessageEqualityComparer.cs (4)
27case InvocationMessage invocationMessage: 28return InvocationMessagesEqual(invocationMessage, (InvocationMessage)y); 67private bool InvocationMessagesEqual(InvocationMessage x, InvocationMessage y)
Microsoft.AspNetCore.SignalR.Client.Core (8)
HubConnection.cs (8)
1134var invocationMessage = new InvocationMessage(irq.InvocationId, methodName, args, streams); 1237var invocationMessage = new InvocationMessage(null, methodName, args, streamIds?.ToArray()); 1281private async Task<CloseMessage?> ProcessMessagesAsync(HubMessage message, ConnectionState connectionState, ChannelWriter<InvocationMessage> invocationMessageWriter) 1304case InvocationMessage invocation: 1364private async Task DispatchInvocationAsync(InvocationMessage invocation, ConnectionState connectionState) 1601var invocationMessageChannel = Channel.CreateUnbounded<InvocationMessage>(_receiveLoopOptions); 1606async Task StartProcessingInvocationMessages(ChannelReader<InvocationMessage> invocationMessageChannelReader) 1610while (invocationMessageChannelReader.TryRead(out var invocationMessage))
Microsoft.AspNetCore.SignalR.Common (3)
Protocol\HubMethodInvocationMessage.cs (3)
65/// Initializes a new instance of the <see cref="InvocationMessage"/> class. 75/// Initializes a new instance of the <see cref="InvocationMessage"/> class. 86/// Initializes a new instance of the <see cref="InvocationMessage"/> class.
Microsoft.AspNetCore.SignalR.Common.Tests (14)
Internal\Protocol\CompositeTestBinder.cs (1)
36arg is InvocationMessage ||
Internal\Protocol\JsonHubProtocolTests.cs (3)
101var expectedMessage = new InvocationMessage("Method", new object[] { 1 }); 133var invocationMessage = Assert.IsType<InvocationMessage>(message);
Internal\Protocol\JsonHubProtocolTestsBase.cs (4)
208Assert.IsType<InvocationMessage>(message); 209Assert.Same(Array.Empty<string>(), (message as InvocationMessage).StreamIds); 281var invocationMessage = Assert.IsType<InvocationMessage>(message);
Internal\Protocol\MessagePackHubProtocolTestBase.cs (1)
239var expectedMessage = new InvocationMessage("xyz", "method", Array.Empty<object>());
Internal\Protocol\TestBinder.cs (1)
23case InvocationMessage i:
Internal\Protocol\TestHubMessageEqualityComparer.cs (4)
27case InvocationMessage invocationMessage: 28return InvocationMessagesEqual(invocationMessage, (InvocationMessage)y); 67private bool InvocationMessagesEqual(InvocationMessage x, InvocationMessage y)
Microsoft.AspNetCore.SignalR.Core (3)
DefaultHubLifetimeManager.cs (1)
358var message = new InvocationMessage(invocationId, methodName, args);
Internal\DefaultHubDispatcher.cs (1)
175case InvocationMessage invocationMessage:
Internal\DefaultHubDispatcherLog.cs (1)
13public static partial void ReceivedHubInvocation(ILogger logger, InvocationMessage invocationMessage);
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
TestBinder.cs (1)
20case InvocationMessage i:
Microsoft.AspNetCore.SignalR.Protocols.Json (2)
Protocol\JsonHubProtocol.cs (2)
526case InvocationMessage m: 640private void WriteInvocationMessage(InvocationMessage message, Utf8JsonWriter writer)
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (2)
Protocol\MessagePackHubProtocolWorker.cs (2)
391case InvocationMessage invocationMessage: 425private void WriteInvocationMessage(InvocationMessage message, ref MessagePackWriter writer)
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (2)
Protocol\NewtonsoftJsonHubProtocol.cs (2)
523case InvocationMessage m: 629private void WriteInvocationMessage(InvocationMessage message, JsonTextWriter writer)
Microsoft.AspNetCore.SignalR.Specification.Tests (38)
HubLifetimeManagerTestBase.cs (23)
48var message = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 53message = Assert.IsType<InvocationMessage>(await client2.ReadAsync().DefaultTimeout()); 81var message = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 111var message = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 142var message = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 167var message = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 190var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 217var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 247var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 305var invocation1 = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 306var invocation2 = Assert.IsType<InvocationMessage>(await client2.ReadAsync().DefaultTimeout()); 359var invocation1 = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout());
ScaleoutHubLifetimeManagerTests.cs (14)
32var message = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 486var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 517var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 569var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout()); 598var invocation2 = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 601var invocation1 = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 649var invocation = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout());
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (1)
228var message = new InvocationMessage(invocationId, methodName, args, streamIds);
Microsoft.AspNetCore.SignalR.StackExchangeRedis (1)
RedisHubLifetimeManager.cs (1)
410var message = new InvocationMessage(invocationId, methodName, args);
Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (6)
DefaultHubMessageSerializerTests.cs (1)
135private static readonly InvocationMessage _testMessage = new InvocationMessage("target", Array.Empty<object>());
RedisHubLifetimeManagerTests.cs (2)
72var message = Assert.IsType<InvocationMessage>(await client2.ReadAsync().DefaultTimeout());
RedisProtocolTests.cs (3)
94private static readonly InvocationMessage _testMessage = new InvocationMessage("target", Array.Empty<object>()); 165var invocation = Assert.IsType<InvocationMessage>(actualMessage);
Microsoft.AspNetCore.SignalR.Tests (97)
DefaultHubLifetimeManagerTests.cs (6)
39var message = Assert.IsType<InvocationMessage>(client1.TryRead()); 215var message = Assert.IsType<InvocationMessage>(client1.TryRead()); 245var message = Assert.IsType<InvocationMessage>(client1.TryRead());
HubConnectionHandlerTests.ClientResult.cs (26)
28var invocationMessage = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 61var invocationMessage = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 149var invocation = Assert.IsType<InvocationMessage>(message); 183var invocation = Assert.IsType<InvocationMessage>(message); 217var invocationMessage = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 253var invocationMessage = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 254var invocationMessage2 = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 255var invocationMessage3 = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 307var invocationMessage = Assert.IsType<InvocationMessage>(await (Task<HubMessage>)task); 376var invocation = Assert.IsType<InvocationMessage>(message); 421var invocation = Assert.IsType<InvocationMessage>(message); 462var invocationMessage = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 500var invocationMessage = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout());
HubConnectionHandlerTests.cs (54)
1389var invocation = Assert.IsType<InvocationMessage>(result); 1427var invocation = Assert.IsType<InvocationMessage>(result); 1462var invocation = Assert.IsType<InvocationMessage>(secondClientResult); 1471invocation = Assert.IsType<InvocationMessage>(firstClientResult); 1503var invocation = Assert.IsType<InvocationMessage>(firstClientResult); 1509invocation = Assert.IsType<InvocationMessage>(secondClientResult); 1574var invocation = Assert.IsType<InvocationMessage>(secondClientResult); 1579invocation = Assert.IsType<InvocationMessage>(thirdClientResult); 1617var invocation = Assert.IsType<InvocationMessage>(secondClientResult); 1622invocation = Assert.IsType<InvocationMessage>(thirdClientResult); 1662var invocation = Assert.IsType<InvocationMessage>(secondClientResult); 1667invocation = Assert.IsType<InvocationMessage>(thirdClientResult); 1716var invocation = Assert.IsType<InvocationMessage>(hubMessage); 1763var invocation = Assert.IsType<InvocationMessage>(hubMessage); 1814var invocation = Assert.IsType<InvocationMessage>(hubMessage); 1857var invocation = Assert.IsType<InvocationMessage>(hubMessage); 1863invocation = Assert.IsType<InvocationMessage>(hubMessage); 1920var invocation = Assert.IsType<InvocationMessage>(hubMessage); 1954var invocation = Assert.IsType<InvocationMessage>(hubMessage); 1987var invocation = Assert.IsType<InvocationMessage>(hubMessage); 2146var completion1 = message1 as InvocationMessage; 2149var completion2 = message2 as InvocationMessage; 2397var message = (InvocationMessage)await client.ReadAsync().DefaultTimeout(); 2427var message = (InvocationMessage)await client.ReadAsync().DefaultTimeout(); 2467var message = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 2563var message = (InvocationMessage)await client1.ReadAsync().DefaultTimeout(); 4524var message = Assert.IsType<InvocationMessage>(await client.ReadAsync().DefaultTimeout()); 4551var invocation = Assert.IsType<InvocationMessage>(message); 4641var invocation = Assert.IsType<InvocationMessage>(message); 5103var message = Assert.IsType<InvocationMessage>(await client1.ReadAsync().DefaultTimeout());
HubConnectionHandlerTestUtils\Utils.cs (3)
42case InvocationMessage expectedInvocation: 43var actualInvocation = Assert.IsType<InvocationMessage>(actual);
Internal\MessageBufferTests.cs (5)
63Assert.IsType<InvocationMessage>(message); 113Assert.IsType<InvocationMessage>(message); 301Assert.IsType<InvocationMessage>(message); 433Assert.IsType<InvocationMessage>(message); 482Assert.IsType<InvocationMessage>(message);
SerializedHubMessageTests.cs (3)
18var invocation = new InvocationMessage("Foo", new object[0]); 32var invocation = new InvocationMessage("Foo", new object[0]); 56var invocation = new InvocationMessage("Foo", new object[0]);
Microsoft.AspNetCore.SignalR.Tests.Utils (1)
TestClient.cs (1)
228var message = new InvocationMessage(invocationId, methodName, args, streamIds);