1 write to Client
Microsoft.AspNetCore.Components.Server (1)
Circuits\CircuitHost.cs (1)
68Client = client ?? throw new ArgumentNullException(nameof(client));
45 references to Client
Microsoft.AspNetCore.Components.Server (28)
Circuits\CircuitFactory.cs (1)
133CreatedCircuit(logger, circuitHost.CircuitId.Id, circuitHost.Client.ConnectionId);
Circuits\CircuitHost.cs (19)
186await TryNotifyClientErrorAsync(Client, GetClientErrorMessage(ex), ex); 282Log.ConnectionUp(_logger, CircuitId, Client.ConnectionId); 312Log.ConnectionDown(_logger, CircuitId, Client.ConnectionId); 385await TryNotifyClientErrorAsync(Client, GetClientErrorMessage(e, $"Failed to complete render batch '{renderId}'.")); 411await TryNotifyClientErrorAsync(Client, GetClientErrorMessage(ex, "Interop call failed.")); 445await TryNotifyClientErrorAsync(Client, GetClientErrorMessage(ex, "Invalid interop arguments.")); 470await TryNotifyClientErrorAsync(Client, GetClientErrorMessage(ex, "Invalid byte array.")); 494await TryNotifyClientErrorAsync(Client, GetClientErrorMessage(ex, "Invalid chunk supplied to stream.")); 514await TryNotifyClientErrorAsync(Client, GetClientErrorMessage(ex, "Unable to send .NET stream.")); 544await TryNotifyClientErrorAsync(Client, GetClientErrorMessage(ex, "Unable to locate .NET stream.")); 581await TryNotifyClientErrorAsync(Client, GetClientErrorMessage(nex, "Location change failed.")); 589await TryNotifyClientErrorAsync(Client, GetClientErrorMessage(ex, $"Location change to '{uri}' failed.")); 607await Client.SendAsync("JS.EndLocationChanging", callId, shouldContinueNavigation); 614await TryNotifyClientErrorAsync(Client, GetClientErrorMessage(ex, $"Location change to '{uri}' failed.")); 711await TryNotifyClientErrorAsync(Client, GetClientErrorMessage(exception), exception); 732if (!Client.Connected) 807await Client.SendAsync("JS.EndUpdateRootComponents", batchId); 816await TryNotifyClientErrorAsync(Client, GetClientErrorMessage(ex), ex); 901var succeded = await Client.InvokeAsync<bool>(
Circuits\CircuitRegistry.cs (8)
125if (!string.Equals(circuitHost.Client.ConnectionId, connectionId, StringComparison.Ordinal)) 127Log.CircuitConnectedToDifferentConnection(_logger, circuitId, circuitHost.Client.ConnectionId); 138circuitHost.Client.SetDisconnected(); 239connectedCircuitHost.Client.Transfer(clientProxy, connectionId); 254disconnectedEntry.CircuitHost.Client.Transfer(clientProxy, connectionId); 349if (!string.Equals(circuitHost.Client.ConnectionId, connectionId, StringComparison.Ordinal)) 352Log.CircuitConnectedToDifferentConnection(_logger, circuitId, circuitHost.Client.ConnectionId); 391circuitHost.Client.SetDisconnected();
Microsoft.AspNetCore.Components.Server.Tests (17)
Circuits\CircuitRegistryTest.cs (17)
53Assert.Same(newClient, circuitHost.Client.Client); 54Assert.Same(newConnectionId, circuitHost.Client.ConnectionId); 78Assert.Same(newClient, circuitHost.Client.Client); 79Assert.Same(newConnectionId, circuitHost.Client.ConnectionId); 167await registry.DisconnectAsync(circuitHost, circuitHost.Client.ConnectionId); 184await registry.DisconnectAsync(circuitHost, circuitHost.Client.ConnectionId); 248var task = registry.DisconnectAsync(circuitHost, circuitHost.Client.ConnectionId); 265Assert.Same(client, circuitHost.Client.Client); 266Assert.Equal(newId, circuitHost.Client.ConnectionId); 305var task = registry.DisconnectAsync(circuitHost, circuitHost.Client.ConnectionId); 358var task = registry.DisconnectAsync(circuitHost, circuitHost.Client.ConnectionId); 391var oldId = circuitHost.Client.ConnectionId; 404Assert.Same(client, circuitHost.Client.Client); 405Assert.Equal(newId, circuitHost.Client.ConnectionId); 479await registry.PauseCircuitAsync(circuitHost, circuitHost.Client.ConnectionId); 509var originalConnectionId = circuitHost.Client.ConnectionId; 553Assert.NotEqual(differentConnectionId, circuitHost.Client.ConnectionId);