25 instantiations of CloseMessage
Microsoft.AspNetCore.Components.Server (1)
src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (1)
238return new CloseMessage(error, allowReconnect);
Microsoft.AspNetCore.Components.Server.Tests (4)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\MessagePackHubProtocolTestBase.cs (4)
189message: new CloseMessage("Error!"), 193message: new CloseMessage(error: null, allowReconnect: true), 197message: new CloseMessage("Error!", allowReconnect: true), 419new MessageSizeTestData("CloseMessage_WithError", new CloseMessage("error"), 10),
Microsoft.AspNetCore.SignalR.Common (1)
Protocol\CloseMessage.cs (1)
17public static readonly CloseMessage Empty = new CloseMessage(error: null, allowReconnect: false);
Microsoft.AspNetCore.SignalR.Common.Tests (10)
Internal\Protocol\JsonHubProtocolTestsBase.cs (6)
86new JsonProtocolTestData("CloseMessage_HasError", new CloseMessage("Error!"), false, true, "{\"type\":7,\"error\":\"Error!\"}"), 87new JsonProtocolTestData("CloseMessage_HasErrorEmptyString", new CloseMessage(""), false, true, "{\"type\":7,\"error\":\"\"}"), 88new JsonProtocolTestData("CloseMessage_HasErrorWithCamelCase", new CloseMessage("Error!"), true, true, "{\"type\":7,\"error\":\"Error!\"}"), 89new JsonProtocolTestData("CloseMessage_HasAllowReconnect", new CloseMessage(error: null, allowReconnect: true), true, true, "{\"type\":7,\"allowReconnect\":true}"), 90new JsonProtocolTestData("CloseMessage_HasErrorAndAllowReconnect", new CloseMessage("Error!", allowReconnect: true), true, true, "{\"type\":7,\"error\":\"Error!\",\"allowReconnect\":true}"), 367new MessageSizeTestData("CloseMessage_WithError", new CloseMessage("error"), 27),
Internal\Protocol\MessagePackHubProtocolTestBase.cs (4)
189message: new CloseMessage("Error!"), 193message: new CloseMessage(error: null, allowReconnect: true), 197message: new CloseMessage("Error!", allowReconnect: true), 419new MessageSizeTestData("CloseMessage_WithError", new CloseMessage("error"), 10),
Microsoft.AspNetCore.SignalR.Core (2)
HubConnectionHandler.cs (2)
246closeMessage = new CloseMessage(errorMessage, allowReconnect); 250closeMessage = new CloseMessage(error: null, allowReconnect);
Microsoft.AspNetCore.SignalR.Protocols.Json (1)
Protocol\JsonHubProtocol.cs (1)
881return new CloseMessage(error, allowReconnect);
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (1)
Protocol\MessagePackHubProtocolWorker.cs (1)
238return new CloseMessage(error, allowReconnect);
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (1)
Protocol\NewtonsoftJsonHubProtocol.cs (1)
872return new CloseMessage(error, allowReconnect);
Microsoft.AspNetCore.SignalR.Tests (4)
HubConnectionHandlerTests.cs (4)
5123await client.SendHubMessageAsync(new CloseMessage(error: null)); 5148await client.SendHubMessageAsync(new CloseMessage(error: errorMessage)); 5263await client.SendHubMessageAsync(new CloseMessage(error: null)); 5319await client.SendHubMessageAsync(new CloseMessage(error: null));
70 references to CloseMessage
Microsoft.AspNetCore.Components.Server (4)
src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (4)
222private static CloseMessage CreateCloseMessage(ref MessagePackReader reader, int itemCount) 235return CloseMessage.Empty; 409case CloseMessage closeMessage: 556private static void WriteCloseMessage(CloseMessage message, ref MessagePackWriter writer)
Microsoft.AspNetCore.Components.Server.Tests (4)
src\SignalR\common\SignalR.Common\test\Internal\Protocol\MessagePackHubProtocolTestBase.cs (2)
185message: CloseMessage.Empty, 418new MessageSizeTestData("CloseMessage_Empty", CloseMessage.Empty, 5),
src\SignalR\common\SignalR.Common\test\Internal\Protocol\TestHubMessageEqualityComparer.cs (2)
40case CloseMessage closeMessage: 41return string.Equals(closeMessage.Error, ((CloseMessage)y).Error);
Microsoft.AspNetCore.SignalR.Client.Core (4)
HubConnection.cs (4)
601var writeTask = SendHubMessage(connectionState, CloseMessage.Empty); 1281private async Task<CloseMessage?> ProcessMessagesAsync(HubMessage message, ConnectionState connectionState, ChannelWriter<InvocationMessage> invocationMessageWriter) 1328case CloseMessage close: 1644CloseMessage? closeMessage = null;
Microsoft.AspNetCore.SignalR.Common (5)
Protocol\CloseMessage.cs (5)
17public static readonly CloseMessage Empty = new CloseMessage(error: null, allowReconnect: false); 25/// If <see langword="false"/>, clients with automatic reconnects enabled should not attempt to automatically reconnect after receiving the <see cref="CloseMessage"/>. 30/// Initializes a new instance of the <see cref="CloseMessage"/> class with an optional error message and <see cref="AllowReconnect"/> set to <see langword="false"/>. 39/// Initializes a new instance of the <see cref="CloseMessage"/> class with an optional error message and a <see cref="bool"/> indicating whether or not a client with 44/// <see langword="true"/>, if client with automatic reconnects enabled should attempt to reconnect after receiving the <see cref="CloseMessage"/>;
Microsoft.AspNetCore.SignalR.Common.Tests (6)
Internal\Protocol\JsonHubProtocolTestsBase.cs (2)
85new JsonProtocolTestData("CloseMessage", CloseMessage.Empty, false, true, "{\"type\":7}"), 366new MessageSizeTestData("CloseMessage_Empty", CloseMessage.Empty, 11),
Internal\Protocol\MessagePackHubProtocolTestBase.cs (2)
185message: CloseMessage.Empty, 418new MessageSizeTestData("CloseMessage_Empty", CloseMessage.Empty, 5),
Internal\Protocol\TestHubMessageEqualityComparer.cs (2)
40case CloseMessage closeMessage: 41return string.Equals(closeMessage.Error, ((CloseMessage)y).Error);
Microsoft.AspNetCore.SignalR.Core (4)
HubConnectionContext.cs (1)
116internal CloseMessage? CloseMessage { get; set; }
HubConnectionHandler.cs (2)
241var closeMessage = CloseMessage.Empty;
Internal\DefaultHubDispatcher.cs (1)
231case CloseMessage closeMessage:
Microsoft.AspNetCore.SignalR.Protocols.Json (4)
Protocol\JsonHubProtocol.cs (4)
554case CloseMessage m: 660private static void WriteCloseMessage(CloseMessage message, Utf8JsonWriter writer) 873private static CloseMessage BindCloseMessage(string? error, bool allowReconnect) 878return CloseMessage.Empty;
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (4)
Protocol\MessagePackHubProtocolWorker.cs (4)
222private static CloseMessage CreateCloseMessage(ref MessagePackReader reader, int itemCount) 235return CloseMessage.Empty; 409case CloseMessage closeMessage: 556private static void WriteCloseMessage(CloseMessage message, ref MessagePackWriter writer)
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (4)
Protocol\NewtonsoftJsonHubProtocol.cs (4)
551case CloseMessage m: 651private static void WriteCloseMessage(CloseMessage message, JsonTextWriter writer) 864private static CloseMessage BindCloseMessage(string? error, bool allowReconnect) 869return CloseMessage.Empty;
Microsoft.AspNetCore.SignalR.Tests (31)
HubConnectionHandlerTests.ClientResult.cs (4)
91var closeMessage = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 119var closeMessage = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout());
HubConnectionHandlerTests.cs (27)
157var close = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 571CloseMessage closeMessage = await client.ReadAsync().DefaultTimeout() as CloseMessage; 964var closeMessage = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 1027var message = Assert.IsType<CloseMessage>(client.TryRead()); 1145Assert.IsType<CloseMessage>(closeMessage); 1541var close = Assert.IsType<CloseMessage>(await firstClient.ReadAsync()); 2292var close = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 2576Assert.IsType<CloseMessage>(client2.TryRead()); 2783case CloseMessage _: 3122var closeMessage = Assert.IsType<CloseMessage>(message); 3156var closeMessage = Assert.IsType<CloseMessage>(message); 3574var closeMessage = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 5125var message = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 5150var message = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout()); 5323var message = Assert.IsType<CloseMessage>(await client.ReadAsync().DefaultTimeout());