18 instantiations of SequenceMessage
Microsoft.AspNetCore.Components.Server (1)
src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (1)
293return new SequenceMessage(ReadInt64(ref reader, "sequenceId"));
Microsoft.AspNetCore.Components.Server.Tests (1)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\MessagePackHubProtocolTestBase.cs (1)
209message: new SequenceMessage(146),
Microsoft.AspNetCore.SignalR.Client.Core (1)
src\SignalR\common\Shared\MessageBuffer.cs (1)
31private readonly SequenceMessage _sequenceMessage = new(0);
Microsoft.AspNetCore.SignalR.Common.Tests (2)
Internal\Protocol\JsonHubProtocolTestsBase.cs (1)
94new JsonProtocolTestData("SequenceMessage", new SequenceMessage(98764321), true, true, "{\"type\":9,\"sequenceId\":98764321}"),
Internal\Protocol\MessagePackHubProtocolTestBase.cs (1)
209message: new SequenceMessage(146),
Microsoft.AspNetCore.SignalR.Core (1)
src\SignalR\common\Shared\MessageBuffer.cs (1)
31private readonly SequenceMessage _sequenceMessage = new(0);
Microsoft.AspNetCore.SignalR.Protocols.Json (1)
Protocol\JsonHubProtocol.cs (1)
901return new SequenceMessage(sequenceId.Value);
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (1)
Protocol\MessagePackHubProtocolWorker.cs (1)
293return new SequenceMessage(ReadInt64(ref reader, "sequenceId"));
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (1)
Protocol\NewtonsoftJsonHubProtocol.cs (1)
892return new SequenceMessage(sequenceId.Value);
Microsoft.AspNetCore.SignalR.Tests (9)
HubConnectionHandlerTests.cs (2)
5197await client.SendHubMessageAsync(new SequenceMessage(10)).DefaultTimeout(); 5279await client.SendHubMessageAsync(new SequenceMessage(1)).DefaultTimeout();
Internal\MessageBufferTests.cs (7)
152Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1))); 171messageBuffer.ShouldProcessMessage(new SequenceMessage(1)); 207Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1))); 228messageBuffer.ShouldProcessMessage(new SequenceMessage(1)); 300Assert.Throws<InvalidOperationException>(() => messageBuffer.ShouldProcessMessage(new SequenceMessage(2))); 485Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1))); 528Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1)));
42 references to SequenceMessage
Microsoft.AspNetCore.Components.Server (3)
src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (3)
291private static SequenceMessage CreateSequenceMessage(ref MessagePackReader reader) 415case SequenceMessage sequenceMessage: 585private static void WriteSequenceMessage(SequenceMessage message, ref MessagePackWriter writer)
Microsoft.AspNetCore.Components.Server.Tests (2)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\TestHubMessageEqualityComparer.cs (2)
44case SequenceMessage sequenceMessage: 45return sequenceMessage.SequenceId == ((SequenceMessage)y).SequenceId;
Microsoft.AspNetCore.SignalR.Client.Core (3)
HubConnection.cs (1)
1364case SequenceMessage sequenceMessage:
src\SignalR\common\Shared\MessageBuffer.cs (2)
31private readonly SequenceMessage _sequenceMessage = new(0); 216if (message is SequenceMessage sequenceMessage)
Microsoft.AspNetCore.SignalR.Common (1)
Protocol\SequenceMessage.cs (1)
12/// Initializes a new instance of the <see cref="SequenceMessage"/> class.
Microsoft.AspNetCore.SignalR.Common.Tests (2)
Internal\Protocol\TestHubMessageEqualityComparer.cs (2)
44case SequenceMessage sequenceMessage: 45return sequenceMessage.SequenceId == ((SequenceMessage)y).SequenceId;
Microsoft.AspNetCore.SignalR.Core (3)
Internal\DefaultHubDispatcher.cs (1)
227case SequenceMessage sequenceMessage:
src\SignalR\common\Shared\MessageBuffer.cs (2)
31private readonly SequenceMessage _sequenceMessage = new(0); 216if (message is SequenceMessage sequenceMessage)
Microsoft.AspNetCore.SignalR.Protocols.Json (3)
Protocol\JsonHubProtocol.cs (3)
562case SequenceMessage m: 678private static void WriteSequenceMessage(SequenceMessage message, Utf8JsonWriter writer) 894private static SequenceMessage BindSequenceMessage(long? sequenceId)
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (3)
Protocol\MessagePackHubProtocolWorker.cs (3)
291private static SequenceMessage CreateSequenceMessage(ref MessagePackReader reader) 415case SequenceMessage sequenceMessage: 585private static void WriteSequenceMessage(SequenceMessage message, ref MessagePackWriter writer)
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (3)
Protocol\NewtonsoftJsonHubProtocol.cs (3)
559case SequenceMessage m: 715private static void WriteSequenceMessage(SequenceMessage message, JsonTextWriter writer) 885private static SequenceMessage BindSequenceMessage(long? sequenceId)
Microsoft.AspNetCore.SignalR.Specification.Tests (1)
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (1)
179case SequenceMessage _:
Microsoft.AspNetCore.SignalR.Tests (17)
HubConnectionHandlerTests.cs (2)
5276var seqMessage = Assert.IsType<SequenceMessage>(await client.ReadAsync().DefaultTimeout());
Internal\MessageBufferTests.cs (15)
108Assert.IsType<SequenceMessage>(message); 158var seqMessage = Assert.IsType<SequenceMessage>(message); 213var seqMessage = Assert.IsType<SequenceMessage>(message); 263var seqMessage = Assert.IsType<SequenceMessage>(message); 295var seqMessage = Assert.IsType<SequenceMessage>(message); 328var seqMessage = Assert.IsType<SequenceMessage>(message); 411Assert.IsType<SequenceMessage>(message); 492Assert.IsType<SequenceMessage>(message); 540Assert.IsType<SequenceMessage>(message); 592Assert.IsType<SequenceMessage>(message);
Microsoft.AspNetCore.SignalR.Tests.Utils (1)
TestClient.cs (1)
179case SequenceMessage _: