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
289 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\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.Components.Server.Tests (15)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\HubMessageHelpers.cs (1)
12public static HubMessage AddHeaders(IDictionary<string, string> headers, HubInvocationMessage hubMessage)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\MessagePackHubProtocolTestBase.cs (9)
230Assert.True(HubProtocol.TryParseMessage(ref data, new TestBinder(testData.Message), out var message)); 255Assert.True(HubProtocol.TryParseMessage(ref data, new TestBinder(expectedMessage), out var message)); 397HubProtocol.TryParseMessage(ref data, binder, out var message); 408var result = HubProtocol.TryParseMessage(ref data, binder, out var message); 450public HubMessage Message { get; } 453public MessageSizeTestData(string name, HubMessage message, int size) 499protected byte[] Write(HubMessage message) 533public HubMessage Message { get; } 535public ProtocolTestData(string name, HubMessage message, string binary)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\TestBinder.cs (1)
16public TestBinder(HubMessage expectedMessage)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\TestHubMessageEqualityComparer.cs (4)
11public class TestHubMessageEqualityComparer : IEqualityComparer<HubMessage> 17public bool Equals(HubMessage x, HubMessage y) 164public int GetHashCode(HubMessage obj)
Microsoft.AspNetCore.SignalR.Client.Core (15)
HubConnection.cs (6)
1201private async Task SendHubMessage(ConnectionState connectionState, HubMessage hubMessage, CancellationToken cancellationToken = default) 1263private async Task SendWithLock(ConnectionState expectedConnectionState, HubMessage message, CancellationToken cancellationToken, [CallerMemberName] string callerName = "") 1281private async Task<CloseMessage?> ProcessMessagesAsync(HubMessage message, ConnectionState connectionState, ChannelWriter<InvocationMessage> invocationMessageWriter) 1646while (_protocol.TryParseMessage(ref buffer, connectionState, out var message)) 2291public ValueTask<FlushResult> WriteAsync(HubMessage message, CancellationToken cancellationToken) 2297public bool ShouldProcessMessage(HubMessage message)
HubConnection.Log.cs (2)
36public static void SendingMessage(ILogger logger, HubMessage message) 57public static void MessageSent(ILogger logger, HubMessage message)
Internal\SerializedHubMessage.cs (4)
26public HubMessage? Message { get; } 46public SerializedHubMessage(HubMessage message) 52/// Gets the serialized representation of the <see cref="HubMessage"/> using the specified <see cref="IHubProtocol"/>. 55/// <returns>The serialized representation of the <see cref="HubMessage"/>.</returns>
src\SignalR\common\Shared\MessageBuffer.cs (3)
127public ValueTask<FlushResult> WriteAsync(HubMessage hubMessage, CancellationToken cancellationToken) 132private async ValueTask<FlushResult> WriteAsyncCore(HubMessage hubMessage, ReadOnlyMemory<byte> messageBytes, CancellationToken cancellationToken) 210internal bool ShouldProcessMessage(HubMessage message)
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (6)
HubProtocolVersionTests.cs (3)
214public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message) => _protocol.GetMessageBytes(message); 221public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, [NotNullWhen(true)] out HubMessage message) 226public void WriteMessage(HubMessage message, IBufferWriter<byte> output)
VersionJsonHubProtocol.cs (3)
30public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, out HubMessage message) 71public void WriteMessage(HubMessage message, IBufferWriter<byte> output) 76public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message)
Microsoft.AspNetCore.SignalR.Client.Tests (3)
HubConnectionTests.cs (3)
996public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, out HubMessage message) 1011public void WriteMessage(HubMessage message, IBufferWriter<byte> output) 1025public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message)
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.Common.Tests (49)
Internal\Protocol\CompositeTestBinder.cs (3)
13private readonly HubMessage[] _hubMessages; 16public CompositeTestBinder(HubMessage[] hubMessages) 33private bool IsBindableMessage(HubMessage arg)
Internal\Protocol\HubMessageHelpers.cs (1)
12public static HubMessage AddHeaders(IDictionary<string, string> headers, HubInvocationMessage hubMessage)
Internal\Protocol\JsonHubProtocolTests.cs (6)
54var ex = Assert.Throws<InvalidDataException>(() => JsonHubProtocol.TryParseMessage(ref data, binder, out var _)); 92protocol.TryParseMessage(ref data, binder, out var message); 105JsonHubProtocol.TryParseMessage(ref data, binder, out var message); 131Assert.True(JsonHubProtocol.TryParseMessage(ref data, binder, out var message)); 164Assert.True(JsonHubProtocol.TryParseMessage(ref data, binder, out var message)); 197Assert.True(JsonHubProtocol.TryParseMessage(ref data, binder, out var message));
Internal\Protocol\JsonHubProtocolTestsBase.cs (18)
147protocol.TryParseMessage(ref data, binder, out var message); 196var ex = Assert.Throws<InvalidDataException>(() => JsonHubProtocol.TryParseMessage(ref data, binder, out var _)); 207JsonHubProtocol.TryParseMessage(ref data, binder, out var message); 223protocol.TryParseMessage(ref data, binder, out var message); 236Assert.True(JsonHubProtocol.TryParseMessage(ref data, binder, out var message)); 256JsonHubProtocol.TryParseMessage(ref data, binder, out var message); 269var ex = Assert.Throws<InvalidDataException>(() => JsonHubProtocol.TryParseMessage(ref data, binder, out var message)); 280JsonHubProtocol.TryParseMessage(ref data, binder, out var message); 295JsonHubProtocol.TryParseMessage(ref data, binder, out var message); 307JsonHubProtocol.TryParseMessage(ref data, binder, out var message); 320JsonHubProtocol.TryParseMessage(ref data, binder, out var message); 442Assert.True(JsonHubProtocol.TryParseMessage(ref data, binder, out var message)); 474Assert.True(JsonHubProtocol.TryParseMessage(ref data, binder, out var hubMessage)); 490Assert.True(JsonHubProtocol.TryParseMessage(ref data, binder, out var hubMessage)); 515public HubMessage Message { get; } 520public JsonProtocolTestData(string name, HubMessage message, bool useCamelCase, bool ignoreNullValues, string json) 535public HubMessage Message { get; } 538public MessageSizeTestData(string name, HubMessage message, int size)
Internal\Protocol\MessagePackHubProtocolTestBase.cs (9)
230Assert.True(HubProtocol.TryParseMessage(ref data, new TestBinder(testData.Message), out var message)); 255Assert.True(HubProtocol.TryParseMessage(ref data, new TestBinder(expectedMessage), out var message)); 397HubProtocol.TryParseMessage(ref data, binder, out var message); 408var result = HubProtocol.TryParseMessage(ref data, binder, out var message); 450public HubMessage Message { get; } 453public MessageSizeTestData(string name, HubMessage message, int size) 499protected byte[] Write(HubMessage message) 533public HubMessage Message { get; } 535public ProtocolTestData(string name, HubMessage message, string binary)
Internal\Protocol\MessagePackHubProtocolTests.cs (5)
38HubProtocol.TryParseMessage(ref bytes, new TestBinder(typeof(DateTime)), out var hubMessage); 67HubProtocol.TryParseMessage(ref bytes, new TestBinder(typeof(DateTimeOffset)), out var hubMessage); 222Assert.True(HubProtocol.TryParseMessage(ref data, binder, out var message)); 252Assert.True(HubProtocol.TryParseMessage(ref data, binder, out var hubMessage)); 265Assert.True(HubProtocol.TryParseMessage(ref data, binder, out var hubMessage));
Internal\Protocol\NewtonsoftJsonHubProtocolTests.cs (2)
52var ex = Assert.Throws<InvalidDataException>(() => JsonHubProtocol.TryParseMessage(ref data, binder, out var _)); 91protocol.TryParseMessage(ref data, binder, out var message);
Internal\Protocol\TestBinder.cs (1)
16public TestBinder(HubMessage expectedMessage)
Internal\Protocol\TestHubMessageEqualityComparer.cs (4)
11public class TestHubMessageEqualityComparer : IEqualityComparer<HubMessage> 17public bool Equals(HubMessage x, HubMessage y) 164public int GetHashCode(HubMessage obj)
Microsoft.AspNetCore.SignalR.Core (20)
DefaultHubLifetimeManager.cs (2)
196var message = CreateInvocationMessage(methodName, args); 280private static HubMessage CreateInvocationMessage(string methodName, object?[] args)
HubConnectionContext.cs (7)
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) 344private async Task WriteSlowAsync(HubMessage message, bool ignoreAbort, CancellationToken cancellationToken) 802internal 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)
21public HubMessage? Message { get; } 41public SerializedHubMessage(HubMessage message) 47/// Gets the serialized representation of the <see cref="HubMessage"/> using the specified <see cref="IHubProtocol"/>. 50/// <returns>The serialized representation of the <see cref="HubMessage"/>.</returns>
src\SignalR\common\Shared\MessageBuffer.cs (3)
127public ValueTask<FlushResult> WriteAsync(HubMessage hubMessage, CancellationToken cancellationToken) 132private async ValueTask<FlushResult> WriteAsyncCore(HubMessage hubMessage, ReadOnlyMemory<byte> messageBytes, CancellationToken cancellationToken) 210internal bool ShouldProcessMessage(HubMessage message)
Microsoft.AspNetCore.SignalR.Microbenchmarks (13)
DefaultHubDispatcherBenchmark.cs (4)
67public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, out HubMessage message) 73public void WriteMessage(HubMessage message, IBufferWriter<byte> output) 77public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message) 92public override ValueTask WriteAsync(HubMessage message, CancellationToken cancellationToken)
HubProtocolBenchmark.cs (1)
15private HubMessage _hubMessage;
RedisHubLifetimeManagerBenchmark.cs (3)
186public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, out HubMessage message) 191public void WriteMessage(HubMessage message, IBufferWriter<byte> output) 196public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message)
RedisProtocolBenchmark.cs (3)
140public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, out HubMessage message) 145public void WriteMessage(HubMessage message, IBufferWriter<byte> output) 150public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message)
ServerSentEventsBenchmark.cs (1)
41HubMessage hubMessage = null;
TestBinder.cs (1)
13public TestBinder(HubMessage expectedMessage)
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)
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (11)
Protocol\MessagePackHubProtocol.cs (3)
60public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, [NotNullWhen(true)] out HubMessage? message) 64public void WriteMessage(HubMessage message, IBufferWriter<byte> output) 68public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message)
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.Protocols.NewtonsoftJson (13)
Protocol\NewtonsoftJsonHubProtocol.cs (13)
79public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, [NotNullWhen(true)] out HubMessage? message) 102public void WriteMessage(HubMessage message, IBufferWriter<byte> output) 109public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message) 114private HubMessage? ParseMessage(Utf8BufferTextReader textReader, IInvocationBinder binder) 338HubMessage message; 513private void WriteMessageCore(HubMessage message, IBufferWriter<byte> stream) 721private static HubMessage BindCancelInvocationMessage(string? invocationId) 731private static HubMessage BindCompletionMessage(string invocationId, string? error, object? result, bool hasResult) 751private static HubMessage BindStreamItemMessage(string invocationId, object? item, bool hasItem) 766private static HubMessage BindStreamInvocationMessage(string? invocationId, string target, object?[]? arguments, bool hasArguments, string[]? streamIds) 788private static HubMessage BindInvocationMessage(string? invocationId, string target, object?[]? arguments, bool hasArguments, string[]? streamIds) 927private static HubMessage ApplyHeaders(HubMessage message, Dictionary<string, string>? headers)
Microsoft.AspNetCore.SignalR.Specification.Tests (15)
src\SignalR\common\testassets\Tests.Utils\HubConnectionContextUtils.cs (1)
49public override ValueTask WriteAsync(HubMessage message, CancellationToken cancellationToken = default)
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (14)
91public Task<IList<HubMessage>> StreamAsync(string methodName, params object[] args) 96public async Task<IList<HubMessage>> StreamAsync(string methodName, string[] streamIds, params object[] args) 102public async Task<IList<HubMessage>> StreamAsync(string methodName, string[] streamIds, IDictionary<string, string> headers, params object[] args) 108public async Task<IList<HubMessage>> ListenAllAsync(string invocationId) 110var result = new List<HubMessage>(); 111await foreach (var item in ListenAsync(invocationId)) 118public async IAsyncEnumerable<HubMessage> ListenAsync(string invocationId) 122var message = await ReadAsync(); 155var message = await ReadAsync(); 232public async Task<string> SendHubMessageAsync(HubMessage message) 240public async Task<HubMessage> ReadAsync(bool isHandshake = false) 244var message = TryRead(isHandshake); 275public HubMessage TryRead(bool isHandshake = false) 288if (_protocol.TryParseMessage(ref buffer, _invocationBinder, out var message))
Microsoft.AspNetCore.SignalR.StackExchangeRedis (3)
Internal\DefaultHubMessageSerializer.cs (1)
27public IReadOnlyList<SerializedMessage> SerializeMessage(HubMessage message)
Internal\RedisProtocol.cs (1)
230private void WriteHubMessage(ref MessagePackWriter writer, HubMessage message)
RedisHubLifetimeManager.cs (1)
667HubMessage? hubMessage = null;
Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (3)
DefaultHubMessageSerializerTests.cs (3)
145public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message) 155public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, out HubMessage message) 160public void WriteMessage(HubMessage message, IBufferWriter<byte> output)
Microsoft.AspNetCore.SignalR.Tests (69)
AddSignalRTests.cs (3)
336public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message) 346public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, out HubMessage message) 351public void WriteMessage(HubMessage message, IBufferWriter<byte> output)
HubConnectionHandlerTests.ClientResult.cs (5)
148var message = await client.ReadAsync().DefaultTimeout(); 182var message = await client.ReadAsync().DefaultTimeout(); 307var invocationMessage = Assert.IsType<InvocationMessage>(await (Task<HubMessage>)task); 375var message = await client.ReadAsync().DefaultTimeout(); 420var message = await client.ReadAsync().DefaultTimeout();
HubConnectionHandlerTests.cs (47)
321var message = await client.ReadAsync(isHandshake: true).DefaultTimeout(); 1144var closeMessage = await client.ReadAsync().DefaultTimeout(); 1385foreach (var result in await Task.WhenAll( 1423foreach (var result in await Task.WhenAll( 1461var secondClientResult = await secondClient.ReadAsync().DefaultTimeout(); 1466var firstClientResult = await firstClient.ReadAsync().DefaultTimeout(); 1502var firstClientResult = await firstClient.ReadAsync().DefaultTimeout(); 1508var secondClientResult = await secondClient.ReadAsync().DefaultTimeout(); 1573var secondClientResult = await secondClient.ReadAsync().DefaultTimeout(); 1578var thirdClientResult = await thirdClient.ReadAsync().DefaultTimeout(); 1616var secondClientResult = await secondClient.ReadAsync().DefaultTimeout(); 1621var thirdClientResult = await thirdClient.ReadAsync().DefaultTimeout(); 1627var hubMessage = await firstClient.ReadAsync().DefaultTimeout(); 1661var secondClientResult = await secondClient.ReadAsync().DefaultTimeout(); 1666var thirdClientResult = await thirdClient.ReadAsync().DefaultTimeout(); 1672var hubMessage = await firstClient.ReadAsync().DefaultTimeout(); 1715var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 1762var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 1813var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 1856var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 1919var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 1953var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 1986var hubMessage = await secondClient.ReadAsync().DefaultTimeout(); 2143var message1 = await client1.ReadAsync().DefaultTimeout(); 2144var message2 = await client2.ReadAsync().DefaultTimeout(); 2722HubMessage message; 2768HubMessage message; 2824var result = await client.ReadAsync().DefaultTimeout(); 2923var result = await client.ReadAsync().DefaultTimeout(); 3120var message = await client.ReadAsync().DefaultTimeout(); 3154var message = await client.ReadAsync().DefaultTimeout(); 3351var firstResult = await client.ReadAsync().DefaultTimeout(); 3357var secondResult = await client.ReadAsync().DefaultTimeout(); 3403var secondResult = await client.ReadAsync().DefaultTimeout(); 3413var firstResult = await client.ReadAsync().DefaultTimeout(); 3470var firstResult = await client.ReadAsync().DefaultTimeout(); 3476var secondResult = await client.ReadAsync().DefaultTimeout(); 3697var response = await client.ReadAsync().DefaultTimeout(); 3929var response = await client.ReadAsync().DefaultTimeout(); 3953var message = client.TryRead(); 3978var message = client.TryRead(); 4067var result = await client.ReadAsync().DefaultTimeout(); 4140var result = await client.ReadAsync().DefaultTimeout(); 4177var result = await client.ReadAsync().DefaultTimeout(); 4227var result = await client.ReadAsync().DefaultTimeout(); 4550var message = await client.ReadAsync().DefaultTimeout(); 4640var message = await client.ReadAsync().DefaultTimeout();
HubConnectionHandlerTestUtils\Utils.cs (2)
27public static void AssertHubMessage(HubMessage expected, HubMessage actual)
Internal\MessageBufferTests.cs (12)
37Assert.True(protocol.TryParseMessage(ref buffer, new TestBinder(), out var message)); 62Assert.True(protocol.TryParseMessage(ref buffer, new TestBinder(), out var message)); 103Assert.True(protocol.TryParseMessage(ref buffer, new TestBinder(), out var message)); 137Assert.True(protocol.TryParseMessage(ref buffer, new TestBinder(), out var message)); 186Assert.True(protocol.TryParseMessage(ref buffer, new TestBinder(), out var message)); 231Assert.True(protocol.TryParseMessage(ref buffer, new TestBinder(), out var message)); 263Assert.True(protocol.TryParseMessage(ref buffer, new TestBinder(), out var message)); 300Assert.True(protocol.TryParseMessage(ref buffer, new TestBinder(), out var message)); 344Assert.True(protocol.TryParseMessage(ref buffer, new TestBinder(), out var message)); 380Assert.True(protocol.TryParseMessage(ref buffer, new TestBinder(), out var message)); 424Assert.True(protocol.TryParseMessage(ref buffer, new TestBinder(), out var message)); 471Assert.True(protocol.TryParseMessage(ref buffer, new TestBinder(), out var message));
Microsoft.AspNetCore.SignalR.Tests.Utils (21)
DummyHubProtocol.cs (6)
14private readonly List<HubMessage> _writtenMessages = new List<HubMessage>(); 29public IReadOnlyList<HubMessage> GetWrittenMessages() 37public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, out HubMessage message) 42public void WriteMessage(HubMessage message, IBufferWriter<byte> output) 47public ReadOnlyMemory<byte> GetMessageBytes(HubMessage message)
HubConnectionContextUtils.cs (1)
49public override ValueTask WriteAsync(HubMessage message, CancellationToken cancellationToken = default)
TestClient.cs (14)
91public Task<IList<HubMessage>> StreamAsync(string methodName, params object[] args) 96public async Task<IList<HubMessage>> StreamAsync(string methodName, string[] streamIds, params object[] args) 102public async Task<IList<HubMessage>> StreamAsync(string methodName, string[] streamIds, IDictionary<string, string> headers, params object[] args) 108public async Task<IList<HubMessage>> ListenAllAsync(string invocationId) 110var result = new List<HubMessage>(); 111await foreach (var item in ListenAsync(invocationId)) 118public async IAsyncEnumerable<HubMessage> ListenAsync(string invocationId) 122var message = await ReadAsync(); 155var message = await ReadAsync(); 232public async Task<string> SendHubMessageAsync(HubMessage message) 240public async Task<HubMessage> ReadAsync(bool isHandshake = false) 244var message = TryRead(isHandshake); 275public HubMessage TryRead(bool isHandshake = false) 288if (_protocol.TryParseMessage(ref buffer, _invocationBinder, out var message))