16 instantiations of AckMessage
Microsoft.AspNetCore.Components.Server (1)
src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (1)
288return new AckMessage(ReadInt64(ref reader, "sequenceId"));
Microsoft.AspNetCore.Components.Server.Tests (1)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\MessagePackHubProtocolTestBase.cs (1)
203message: new AckMessage(42),
Microsoft.AspNetCore.SignalR.Client.Core (1)
src\SignalR\common\Shared\MessageBuffer.cs (1)
30private readonly AckMessage _ackMessage = new(0);
Microsoft.AspNetCore.SignalR.Common.Tests (2)
Internal\Protocol\JsonHubProtocolTestsBase.cs (1)
92new JsonProtocolTestData("AckMessage", new AckMessage(102020), true, true, "{\"type\":8,\"sequenceId\":102020}"),
Internal\Protocol\MessagePackHubProtocolTestBase.cs (1)
203message: new AckMessage(42),
Microsoft.AspNetCore.SignalR.Core (1)
src\SignalR\common\Shared\MessageBuffer.cs (1)
30private readonly AckMessage _ackMessage = new(0);
Microsoft.AspNetCore.SignalR.Protocols.Json (1)
Protocol\JsonHubProtocol.cs (1)
891return new AckMessage(sequenceId.Value);
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (1)
Protocol\MessagePackHubProtocolWorker.cs (1)
288return new AckMessage(ReadInt64(ref reader, "sequenceId"));
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (1)
Protocol\NewtonsoftJsonHubProtocol.cs (1)
882return new AckMessage(sequenceId.Value);
Microsoft.AspNetCore.SignalR.Tests (7)
HubConnectionHandlerTests.cs (2)
5180await client.SendHubMessageAsync(new AckMessage(234)).DefaultTimeout(); 5218await client.SendHubMessageAsync(new AckMessage(1)).DefaultTimeout();
Internal\MessageBufferTests.cs (5)
70await messageBuffer.AckAsync(new AckMessage(1)); 191await messageBuffer.AckAsync(new AckMessage(1)); 255await messageBuffer.AckAsync(new AckMessage(ackNum)); 308await messageBuffer.AckAsync(new AckMessage(1)); 420var ackTask = messageBuffer.AckAsync(new AckMessage(3));
31 references to AckMessage
Microsoft.AspNetCore.Components.Server (3)
src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (3)
286private static AckMessage CreateAckMessage(ref MessagePackReader reader) 412case AckMessage ackMessage: 578private static void WriteAckMessage(AckMessage message, ref MessagePackWriter writer)
Microsoft.AspNetCore.Components.Server.Tests (2)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\TestHubMessageEqualityComparer.cs (2)
42case AckMessage ackMessage: 43return ackMessage.SequenceId == ((AckMessage)y).SequenceId;
Microsoft.AspNetCore.SignalR.Client.Core (4)
HubConnection.cs (2)
1350case AckMessage ackMessage: 2310public Task AckAsync(AckMessage ackMessage)
src\SignalR\common\Shared\MessageBuffer.cs (2)
30private readonly AckMessage _ackMessage = new(0); 183public async Task AckAsync(AckMessage ackMessage)
Microsoft.AspNetCore.SignalR.Common (1)
Protocol\AckMessage.cs (1)
12/// Initializes a new instance of the <see cref="AckMessage"/> class.
Microsoft.AspNetCore.SignalR.Common.Tests (2)
Internal\Protocol\TestHubMessageEqualityComparer.cs (2)
42case AckMessage ackMessage: 43return ackMessage.SequenceId == ((AckMessage)y).SequenceId;
Microsoft.AspNetCore.SignalR.Core (4)
HubConnectionContext.cs (1)
792internal Task AckAsync(AckMessage ackMessage)
Internal\DefaultHubDispatcher.cs (1)
223case AckMessage ackMessage:
src\SignalR\common\Shared\MessageBuffer.cs (2)
30private readonly AckMessage _ackMessage = new(0); 183public async Task AckAsync(AckMessage ackMessage)
Microsoft.AspNetCore.SignalR.Protocols.Json (3)
Protocol\JsonHubProtocol.cs (3)
558case AckMessage m: 673private static void WriteAckMessage(AckMessage message, Utf8JsonWriter writer) 884private static AckMessage BindAckMessage(long? sequenceId)
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (3)
Protocol\MessagePackHubProtocolWorker.cs (3)
286private static AckMessage CreateAckMessage(ref MessagePackReader reader) 412case AckMessage ackMessage: 578private static void WriteAckMessage(AckMessage message, ref MessagePackWriter writer)
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (3)
Protocol\NewtonsoftJsonHubProtocol.cs (3)
555case AckMessage m: 709private static void WriteAckMessage(AckMessage message, JsonTextWriter writer) 875private static AckMessage BindAckMessage(long? sequenceId)
Microsoft.AspNetCore.SignalR.Specification.Tests (1)
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (1)
176case AckMessage _:
Microsoft.AspNetCore.SignalR.Tests (4)
Internal\MessageBufferTests.cs (4)
381var ackMessage = Assert.IsType<AckMessage>(message); 393ackMessage = Assert.IsType<AckMessage>(message); 491Assert.IsType<AckMessage>(message);
Microsoft.AspNetCore.SignalR.Tests.Utils (1)
TestClient.cs (1)
176case AckMessage _: