13 instantiations of InvocationMessage
Microsoft.AspNetCore.Components.Server (1)
src\aspnetcore\src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (1)
106return ApplyHeaders(headers, new InvocationMessage(invocationId, target, arguments, streams));
Microsoft.AspNetCore.SignalR.Client.Core (2)
HubConnection.cs (2)
1140var invocationMessage = new InvocationMessage(irq.InvocationId, methodName, args, streams); 1243var invocationMessage = new InvocationMessage(null, methodName, args, streamIds?.ToArray());
Microsoft.AspNetCore.SignalR.Core (2)
DefaultHubLifetimeManager.cs (2)
282return new InvocationMessage(methodName, args); 358var message = new InvocationMessage(invocationId, methodName, args);
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\aspnetcore\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);
64 references to InvocationMessage
Microsoft.AspNetCore.Components.Server (2)
src\aspnetcore\src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (2)
391case InvocationMessage invocationMessage: 425private void WriteInvocationMessage(InvocationMessage message, ref MessagePackWriter writer)
Microsoft.AspNetCore.SignalR.Client.Core (8)
HubConnection.cs (8)
1140var invocationMessage = new InvocationMessage(irq.InvocationId, methodName, args, streams); 1243var invocationMessage = new InvocationMessage(null, methodName, args, streamIds?.ToArray()); 1287private async Task<CloseMessage?> ProcessMessagesAsync(HubMessage message, ConnectionState connectionState, ChannelWriter<InvocationMessage> invocationMessageWriter) 1314case InvocationMessage invocation: 1374private async Task DispatchInvocationAsync(InvocationMessage invocation, ConnectionState connectionState) 1611var invocationMessageChannel = Channel.CreateUnbounded<InvocationMessage>(_receiveLoopOptions); 1616async Task StartProcessingInvocationMessages(ChannelReader<InvocationMessage> invocationMessageChannelReader) 1620while (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.Core (6)
_generated\0\LoggerMessage.g.cs (3)
347private static readonly global::System.Action<global::Microsoft.Extensions.Logging.ILogger, global::Microsoft.AspNetCore.SignalR.Protocol.InvocationMessage, global::System.Exception?> __ReceivedHubInvocationCallback = 348global::Microsoft.Extensions.Logging.LoggerMessage.Define<global::Microsoft.AspNetCore.SignalR.Protocol.InvocationMessage>(global::Microsoft.Extensions.Logging.LogLevel.Debug, new global::Microsoft.Extensions.Logging.EventId(1, "ReceivedHubInvocation"), "Received hub invocation: {InvocationMessage}.", new global::Microsoft.Extensions.Logging.LogDefineOptions() { SkipEnabledCheck = true }); 355public static partial void ReceivedHubInvocation(global::Microsoft.Extensions.Logging.ILogger logger, global::Microsoft.AspNetCore.SignalR.Protocol.InvocationMessage invocationMessage)
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.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\aspnetcore\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);