22 instantiations of SerializedHubMessage
Microsoft.AspNetCore.SignalR.Core (1)
DefaultHubLifetimeManager.cs (1)
277return new SerializedHubMessage(CreateInvocationMessage(methodName, args));
Microsoft.AspNetCore.SignalR.StackExchangeRedis (1)
Internal\RedisProtocol.cs (1)
261return new SerializedHubMessage(serializations);
Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (3)
RedisProtocolTests.cs (3)
101() => new RedisInvocation(new SerializedHubMessage(_testMessage), null), 111() => new RedisInvocation(new SerializedHubMessage(_testMessage), new [] { "a" }), 122() => new RedisInvocation(new SerializedHubMessage(_testMessage), new [] { "a", "b", "c", "d", "e", "f" }),
Microsoft.AspNetCore.SignalR.Tests (17)
Internal\MessageBufferTests.cs (14)
57await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[100000] })), cancelableToken); 59var writeTask = messageBuffer.WriteAsync(new SerializedHubMessage(new StreamItemMessage("id", null)), cancelableToken); 96await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[40] })), cancelableToken); 99var writeTask = messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[40] })), cancelableToken); 188var invocationMessage = new SerializedHubMessage([new SerializedMessage(protocol.Name, 357await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { 1 })), cancelableToken); 359var writeTask = messageBuffer.WriteAsync(new SerializedHubMessage(new StreamItemMessage("id", null)), cancelableToken); 476await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[10] })), cancelableToken); 477await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[100] })), cancelableToken).DefaultTimeout(); 478var writeTask = messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[100] })), cancelableToken); 520await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[10] })), cancelableToken); 521var writeTask = messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[100] })), cancelableToken).DefaultTimeout(); 576await messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[40] })), cts.Token); 579var writeTask = messageBuffer.WriteAsync(new SerializedHubMessage(new InvocationMessage("t", new object[] { new byte[40] })), cts.Token);
SerializedHubMessageTests.cs (3)
19var message = new SerializedHubMessage(invocation); 33var message = new SerializedHubMessage(invocation); 57var message = new SerializedHubMessage(invocation);
21 references to SerializedHubMessage
Microsoft.AspNetCore.SignalR.Core (13)
DefaultHubLifetimeManager.cs (6)
102SerializedHubMessage? message = null; 147private static void SendToGroupConnections(string methodName, object?[] args, ConcurrentDictionary<string, HubConnectionContext> connections, Func<HubConnectionContext, object?, bool>? include, object? state, ref List<Task>? tasks, ref SerializedHubMessage? message, CancellationToken cancellationToken) 212SerializedHubMessage? message = null; 229SerializedHubMessage? message = null; 262SerializedHubMessage? message = null; 275private static SerializedHubMessage CreateSerializedInvocationMessage(string methodName, object?[] args)
HubConnectionContext.cs (4)
231public virtual ValueTask WriteAsync(SerializedHubMessage message, CancellationToken cancellationToken = default) 319private ValueTask<FlushResult> WriteCore(SerializedHubMessage message, CancellationToken cancellationToken) 329SerializedHubMessage message, CancellationToken cancellationToken) 409private async Task WriteSlowAsync(SerializedHubMessage message, CancellationToken cancellationToken)
SerializedHubMessage.cs (2)
25/// Initializes a new instance of the <see cref="SerializedHubMessage"/> class. 39/// Initializes a new instance of the <see cref="SerializedHubMessage"/> class.
src\SignalR\common\Shared\MessageBuffer.cs (1)
122public ValueTask<FlushResult> WriteAsync(SerializedHubMessage hubMessage, CancellationToken cancellationToken)
Microsoft.AspNetCore.SignalR.StackExchangeRedis (4)
Internal\RedisInvocation.cs (2)
17public SerializedHubMessage Message { get; } 23public RedisInvocation(SerializedHubMessage message, IReadOnlyList<string>? excludedConnectionIds,
Internal\RedisProtocol.cs (2)
194var message = ReadSerializedHubMessage(ref reader); 249public static SerializedHubMessage ReadSerializedHubMessage(ref MessagePackReader reader)
Microsoft.AspNetCore.SignalR.Tests (4)
Internal\MessageBufferTests.cs (1)
188var invocationMessage = new SerializedHubMessage([new SerializedMessage(protocol.Name,
SerializedHubMessageTests.cs (3)
19var message = new SerializedHubMessage(invocation); 33var message = new SerializedHubMessage(invocation); 57var message = new SerializedHubMessage(invocation);