6 instantiations of CompletionMessage
Microsoft.AspNetCore.Components.Server (1)
src\aspnetcore\src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (1)
210return ApplyHeaders(headers, new CompletionMessage(invocationId, error, result, hasResult));
Microsoft.AspNetCore.SignalR.Common (3)
Protocol\CompletionMessage.cs (3)
66=> new CompletionMessage(invocationId, error, result: null, hasResult: false); 75=> new CompletionMessage(invocationId, error: null, result: payload, hasResult: true); 84=> new CompletionMessage(invocationId, error: null, result: null, hasResult: false);
Microsoft.AspNetCore.SignalR.Protocols.Json (2)
Protocol\JsonHubProtocol.cs (2)
752return new CompletionMessage(invocationId, error, result, hasResult: true); 755return new CompletionMessage(invocationId, error, result: null, hasResult: false);
37 references to CompletionMessage
Microsoft.AspNetCore.Components.Server (3)
src\aspnetcore\src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (3)
159private CompletionMessage CreateCompletionMessage(ref MessagePackReader reader, IInvocationBinder binder) 400case CompletionMessage completionMessage: 525private void WriteCompletionMessage(CompletionMessage message, ref MessagePackWriter writer)
Microsoft.AspNetCore.SignalR.Common (11)
Protocol\CompletionMessage.cs (10)
30/// Constructs a <see cref="CompletionMessage"/>. 60/// Constructs a <see cref="CompletionMessage"/> with an error. 64/// <returns>The constructed <see cref="CompletionMessage"/>.</returns> 65public static CompletionMessage WithError(string invocationId, string? error) 69/// Constructs a <see cref="CompletionMessage"/> with a result. 73/// <returns>The constructed <see cref="CompletionMessage"/>.</returns> 74public static CompletionMessage WithResult(string invocationId, object? payload) 78/// Constructs a <see cref="CompletionMessage"/> without an error or result. 82/// <returns>The constructed <see cref="CompletionMessage"/>.</returns> 83public static CompletionMessage Empty(string invocationId)
Protocol\RawResult.cs (1)
23/// Stores the raw serialized bytes of a <see cref="CompletionMessage.Result"/> for forwarding to another server.
Microsoft.AspNetCore.SignalR.Core (21)
DefaultHubLifetimeManager.cs (1)
384public override Task SetConnectionResultAsync(string connectionId, CompletionMessage result)
HubLifetimeManager.cs (1)
158public virtual Task SetConnectionResultAsync(string connectionId, CompletionMessage result)
Internal\DefaultHubDispatcher.cs (10)
205case CompletionMessage completionMessage: 260var message = CompletionMessage.WithError(bindingFailureMessage.Id, errorString); 292return connection.WriteAsync(CompletionMessage.WithError( 445await connection.WriteAsync(CompletionMessage.WithResult(hubMethodInvocationMessage.InvocationId, result)); 499connection.StreamTracker.TryComplete(CompletionMessage.Empty(stream)); 602await connection.WriteAsync(CompletionMessage.WithError(invocationId, error)); 655await connection.WriteAsync(CompletionMessage.WithError(invocationId, errorMessage)); 699await connection.WriteAsync(CompletionMessage.WithError(hubMethodInvocationMessage.InvocationId, 709await connection.WriteAsync(CompletionMessage.WithError(hubMethodInvocationMessage.InvocationId!,
Internal\DefaultHubDispatcherLog.cs (2)
83public static void CompletingStream(ILogger logger, CompletionMessage message) 89public static void ClosingStreamWithBindingError(ILogger logger, CompletionMessage message)
src\aspnetcore\src\SignalR\common\Shared\ClientResultsManager.cs (6)
16private readonly ConcurrentDictionary<string, (Type Type, string ConnectionId, object Tcs, Action<object, CompletionMessage> Complete)> _pendingInvocations = new(); 41public void AddInvocation(string invocationId, (Type Type, string ConnectionId, object Tcs, Action<object, CompletionMessage> Complete) invocationInfo) 48invocationInfo.Complete(invocationInfo.Tcs, CompletionMessage.WithError(invocationId, "ID collision occurred when using client results. This is likely a bug in SignalR.")); 52public void TryCompleteResult(string connectionId, CompletionMessage message) 75public (Type Type, string ConnectionId, object Tcs, Action<object, CompletionMessage> Completion)? RemoveInvocation(string invocationId) 152_clientResultsManager.TryCompleteResult(_connectionId, CompletionMessage.WithError(_invocationId, "Invocation canceled by the server."));
StreamTracker.cs (1)
74public bool TryComplete(CompletionMessage message)
Microsoft.AspNetCore.SignalR.Protocols.Json (2)
Protocol\JsonHubProtocol.cs (2)
541case CompletionMessage m: 592private void WriteCompletionMessage(CompletionMessage message, Utf8JsonWriter writer)