5 writes to SequenceId
Microsoft.AspNetCore.SignalR.Client.Core (2)
src\SignalR\common\Shared\MessageBuffer.cs (2)
262_sequenceMessage.SequenceId = _totalMessageCount + 1; 273_sequenceMessage.SequenceId = item.SequenceId;
Microsoft.AspNetCore.SignalR.Common (1)
Protocol\SequenceMessage.cs (1)
17SequenceId = sequenceId;
Microsoft.AspNetCore.SignalR.Core (2)
src\SignalR\common\Shared\MessageBuffer.cs (2)
262_sequenceMessage.SequenceId = _totalMessageCount + 1; 273_sequenceMessage.SequenceId = item.SequenceId;
20 references to SequenceId
Microsoft.AspNetCore.Components.Server (1)
src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (1)
589writer.Write(message.SequenceId);
Microsoft.AspNetCore.Components.Server.Tests (2)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\TestHubMessageEqualityComparer.cs (2)
45return sequenceMessage.SequenceId == ((SequenceMessage)y).SequenceId;
Microsoft.AspNetCore.SignalR.Client.Core (3)
HubConnection.cs (1)
1355Log.ReceivedSequenceMessage(_logger, sequenceMessage.SequenceId);
src\SignalR\common\Shared\MessageBuffer.cs (2)
216if (sequenceMessage.SequenceId > _currentReceivingSequenceId) 221_currentReceivingSequenceId = sequenceMessage.SequenceId;
Microsoft.AspNetCore.SignalR.Common (1)
Protocol\SequenceMessage.cs (1)
7/// Represents the restart of the sequence of messages being sent. <see cref="SequenceId"/> is the starting ID of messages being sent, which might be duplicate messages.
Microsoft.AspNetCore.SignalR.Common.Tests (2)
Internal\Protocol\TestHubMessageEqualityComparer.cs (2)
45return sequenceMessage.SequenceId == ((SequenceMessage)y).SequenceId;
Microsoft.AspNetCore.SignalR.Core (3)
Internal\DefaultHubDispatcher.cs (1)
228Log.ReceivedSequenceMessage(_logger, sequenceMessage.SequenceId);
src\SignalR\common\Shared\MessageBuffer.cs (2)
216if (sequenceMessage.SequenceId > _currentReceivingSequenceId) 221_currentReceivingSequenceId = sequenceMessage.SequenceId;
Microsoft.AspNetCore.SignalR.Protocols.Json (1)
Protocol\JsonHubProtocol.cs (1)
680writer.WriteNumber(SequenceIdPropertyName, message.SequenceId);
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (1)
Protocol\MessagePackHubProtocolWorker.cs (1)
589writer.Write(message.SequenceId);
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (1)
Protocol\NewtonsoftJsonHubProtocol.cs (1)
718writer.WriteValue(message.SequenceId);
Microsoft.AspNetCore.SignalR.Tests (5)
HubConnectionHandlerTests.cs (1)
5259Assert.Equal(1, seqMessage.SequenceId);
Internal\MessageBufferTests.cs (4)
154Assert.Equal(1, seqMessage.SequenceId); 201Assert.Equal(2, seqMessage.SequenceId); 233Assert.Equal(1, seqMessage.SequenceId); 265Assert.Equal(ackNum + 1, seqMessage.SequenceId);