16 references to 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 (7)
HubConnectionHandlerTests.cs (2)
5179await client.SendHubMessageAsync(new SequenceMessage(10)).DefaultTimeout(); 5261await client.SendHubMessageAsync(new SequenceMessage(1)).DefaultTimeout();
Internal\MessageBufferTests.cs (5)
147Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1))); 166messageBuffer.ShouldProcessMessage(new SequenceMessage(1)); 237Assert.Throws<InvalidOperationException>(() => messageBuffer.ShouldProcessMessage(new SequenceMessage(2))); 418Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1))); 460Assert.True(messageBuffer.ShouldProcessMessage(new SequenceMessage(1)));