8 types derived from HubMessage
Microsoft.AspNetCore.SignalR.Common (8)
Protocol\AckMessage.cs (1)
9public sealed class AckMessage : HubMessage
Protocol\CloseMessage.cs (1)
12public class CloseMessage : HubMessage
Protocol\HandshakeRequestMessage.cs (1)
9public class HandshakeRequestMessage : HubMessage
Protocol\HandshakeResponseMessage.cs (1)
9public class HandshakeResponseMessage : HubMessage
Protocol\HubInvocationMessage.cs (1)
11public abstract class HubInvocationMessage : HubMessage
Protocol\PingMessage.cs (1)
9public class PingMessage : HubMessage
Protocol\SequenceMessage.cs (1)
9public sealed class SequenceMessage : HubMessage
Protocol\StreamBindingFailureMessage.cs (1)
17public class StreamBindingFailureMessage : HubMessage
53 references to HubMessage
Microsoft.AspNetCore.Components.Server (11)
BlazorPack\BlazorPackHubProtocol.cs (3)
39public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, out HubMessage message) 43public void WriteMessage(HubMessage message, IBufferWriter<byte> output) 47public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message)
src\aspnetcore\src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (8)
28public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, [NotNullWhen(true)] out HubMessage? message) 41private HubMessage? ParseMessage(ref MessagePackReader reader, IInvocationBinder binder) 73private HubMessage CreateInvocationMessage(ref MessagePackReader reader, IInvocationBinder binder, int itemCount) 109private HubMessage CreateStreamInvocationMessage(ref MessagePackReader reader, IInvocationBinder binder, int itemCount) 139private HubMessage CreateStreamItemMessage(ref MessagePackReader reader, IInvocationBinder binder) 335public void WriteMessage(HubMessage message, IBufferWriter<byte> output) 357public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message) 387private void WriteMessageCore(HubMessage message, ref MessagePackWriter writer)
Microsoft.AspNetCore.SignalR.Common (9)
Protocol\HubProtocolExtensions.cs (2)
14/// Converts the specified <see cref="HubMessage"/> to its serialized representation. 19public static byte[] GetMessageBytes(this IHubProtocol hubProtocol, HubMessage message)
Protocol\IHubProtocol.cs (7)
32/// Creates a new <see cref="HubMessage"/> from the specified serialized representation, and using the specified binder. 37/// <returns>A value that is <c>true</c> if the <see cref="HubMessage"/> was successfully parsed; otherwise, <c>false</c>.</returns> 38bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, [NotNullWhen(true)] out HubMessage? message); 41/// Writes the specified <see cref="HubMessage"/> to a writer. 45void WriteMessage(HubMessage message, IBufferWriter<byte> output); 48/// Converts the specified <see cref="HubMessage"/> to its serialized representation. 52ReadOnlyMemory<byte> GetMessageBytes(HubMessage message);
Microsoft.AspNetCore.SignalR.Core (20)
DefaultHubLifetimeManager.cs (2)
196var message = CreateInvocationMessage(methodName, args); 280private static HubMessage CreateInvocationMessage(string methodName, object?[] args)
HubConnectionContext.cs (8)
175/// Write a <see cref="HubMessage"/> to the connection. 177/// <param name="message">The <see cref="HubMessage"/> being written.</param> 181public virtual ValueTask WriteAsync(HubMessage message, CancellationToken cancellationToken = default) 186internal ValueTask WriteAsync(HubMessage message, bool ignoreAbort, CancellationToken cancellationToken = default) 268private ValueTask<FlushResult> WriteCore(HubMessage message, CancellationToken cancellationToken) 277HubMessage message, CancellationToken cancellationToken) 375private async Task WriteSlowAsync(HubMessage message, bool ignoreAbort, CancellationToken cancellationToken) 839internal bool ShouldProcessMessage(HubMessage message)
HubConnectionHandler.cs (2)
289while (protocol.TryParseMessage(ref buffer, binder, out var message)) 318if (protocol.TryParseMessage(ref segment, binder, out var message))
Internal\DefaultHubDispatcher.cs (1)
154public override Task DispatchMessageAsync(HubConnectionContext connection, HubMessage hubMessage)
Internal\HubDispatcher.cs (1)
13public abstract Task DispatchMessageAsync(HubConnectionContext connection, HubMessage hubMessage);
SerializedHubMessage.cs (4)
22public HubMessage? Message { get; } 42public SerializedHubMessage(HubMessage message) 50/// Gets the serialized representation of the <see cref="HubMessage"/> using the specified <see cref="IHubProtocol"/>. 53/// <returns>The serialized representation of the <see cref="HubMessage"/>.</returns>
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (2)
129public ValueTask<FlushResult> WriteAsync(HubMessage hubMessage, CancellationToken cancellationToken) 218internal bool ShouldProcessMessage(HubMessage message)
Microsoft.AspNetCore.SignalR.Protocols.Json (13)
Protocol\JsonHubProtocol.cs (13)
89public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, [NotNullWhen(true)] out HubMessage? message) 103public void WriteMessage(HubMessage message, IBufferWriter<byte> output) 110public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message) 115private HubMessage? ParseMessage(ReadOnlySequence<byte> input, IInvocationBinder binder) 348HubMessage message; 516private void WriteMessageCore(HubMessage message, IBufferWriter<byte> stream) 728private static HubMessage BindCancelInvocationMessage(string? invocationId) 738private static HubMessage BindCompletionMessage(string invocationId, string? error, object? result, bool hasResult) 758private static HubMessage BindStreamItemMessage(string invocationId, object? item, bool hasItem) 773private static HubMessage BindStreamInvocationMessage(string? invocationId, string target, 796private static HubMessage BindInvocationMessage(string? invocationId, string target, 904private static HubMessage ApplyHeaders(HubMessage message, Dictionary<string, string>? headers)