1 type derived from CircuitHost
Microsoft.AspNetCore.Components.Server.Tests (1)
Circuits\TestCircuitHost.cs (1)
18internal class TestCircuitHost : CircuitHost
2 instantiations of CircuitHost
Microsoft.AspNetCore.Components.Server (1)
Circuits\CircuitFactory.cs (1)
105var circuitHost = new CircuitHost(
Microsoft.AspNetCore.Components.Server.Tests (1)
Circuits\CircuitPersistenceManagerTest.cs (1)
444var circuitHost = new CircuitHost(
133 references to CircuitHost
Microsoft.AspNetCore.Components.Server (52)
Circuits\Circuit.cs (2)
11private readonly CircuitHost _circuitHost; 13internal Circuit(CircuitHost circuitHost)
Circuits\CircuitFactory.cs (4)
41public async ValueTask<CircuitHost> CreateCircuitHostAsync( 105var circuitHost = new CircuitHost( 117_loggerFactory.CreateLogger<CircuitHost>()); 132internal static void CreatedCircuit(ILogger logger, CircuitHost circuitHost) =>
Circuits\CircuitHandle.cs (1)
12public CircuitHost CircuitHost { get; set; }
Circuits\CircuitHandleRegistry.cs (2)
18public CircuitHost GetCircuit(IDictionary<object, object?> circuitHandles, object circuitKey) 28public void SetCircuit(IDictionary<object, object?> circuitHandles, object circuitKey, CircuitHost circuitHost)
Circuits\CircuitPersistenceManager.cs (2)
22public async Task PauseCircuitAsync(CircuitHost circuit, bool saveStateToClient = false, CancellationToken cancellation = default) 46internal async Task SaveStateToClient(CircuitHost circuit, PersistedCircuitState state, CancellationToken cancellation = default)
Circuits\CircuitRegistry.cs (22)
15/// <see cref="CircuitRegistry"/> manages the lifetime of a <see cref="CircuitHost"/>. 18/// Hosts start off by being registered using <see cref="CircuitHost"/>. 57ConnectedCircuits = new ConcurrentDictionary<CircuitId, CircuitHost>(); 70internal ConcurrentDictionary<CircuitId, CircuitHost> ConnectedCircuits { get; } 75/// Registers an active <see cref="CircuitHost"/> with the register. 77public void Register(CircuitHost circuitHost) 90public virtual Task DisconnectAsync(CircuitHost circuitHost, string connectionId) 114protected virtual bool DisconnectCore(CircuitHost circuitHost, string connectionId) 146public void RegisterDisconnectedCircuit(CircuitHost circuitHost) 172public virtual async Task<CircuitHost> ConnectAsync(CircuitId circuitId, ISingleClientProxy clientProxy, string connectionId, CancellationToken cancellationToken) 176CircuitHost circuitHost; 231protected virtual (CircuitHost circuitHost, bool previouslyConnected) ConnectCore(CircuitId circuitId, ISingleClientProxy clientProxy, string connectionId) 233if (ConnectedCircuits.TryGetValue(circuitId, out var connectedCircuitHost)) 294var circuitHost = entry.CircuitHost; 310private async Task PauseAndDisposeCircuitHost(CircuitHost circuitHost, bool saveStateToClient) 318CircuitHost circuitHost, 338internal virtual Task PauseCore(CircuitHost circuitHost, string connectionId) 381CircuitHost circuitHost; 408var circuitHost = (CircuitHost)sender; 424public DisconnectedCircuitEntry(CircuitHost circuitHost, CancellationTokenSource tokenSource) 430public CircuitHost CircuitHost { get; }
Circuits\ICircuitFactory.cs (1)
10ValueTask<CircuitHost> CreateCircuitHostAsync(
Circuits\ICircuitHandleRegistry.cs (2)
10CircuitHost GetCircuit(IDictionary<object, object?> circuitHandles, object circuitKey); 12void SetCircuit(IDictionary<object, object?> circuitHandles, object circuitKey, CircuitHost circuitHost);
ComponentHub.cs (16)
78var circuitHost = _circuitHandleRegistry.GetCircuit(Context.Items, CircuitKey); 89var circuitHost = _circuitHandleRegistry.GetCircuit(Context.Items, CircuitKey); 171var circuitHost = await GetActiveCircuitAsync(); 222var circuitHost = await _circuitRegistry.ConnectAsync( 286var circuitHost = _circuitHandleRegistry.GetCircuit(Context.Items, CircuitKey); 418var circuitHost = await GetActiveCircuitAsync(); 434var circuitHost = await GetActiveCircuitAsync(); 445var circuitHost = await GetActiveCircuitAsync(); 456var circuitHost = await GetActiveCircuitAsync(); 467var circuitHost = await GetActiveCircuitAsync(); 483var circuitHost = await GetActiveCircuitAsync(); 518var circuitHost = await GetActiveCircuitAsync(); 530var circuitHost = await GetActiveCircuitAsync(); 541var circuitHost = await GetActiveCircuitAsync(); 556private async ValueTask<CircuitHost> GetActiveCircuitAsync([CallerMemberName] string callSite = "") 559var circuitHost = handle?.CircuitHost;
Microsoft.AspNetCore.Components.Server.Tests (81)
CircuitDisconnectMiddlewareTest.cs (2)
178var testCircuitHost = TestCircuitHost.Create(circuitId); 216var circuitHost = TestCircuitHost.Create(circuitId);
Circuits\CircuitHostTest.cs (24)
31var circuitHost = TestCircuitHost.Create( 56var circuitHost = TestCircuitHost.Create( 80var circuitHost = TestCircuitHost.Create( 103var circuitHost = TestCircuitHost.Create( 133var circuitHost = TestCircuitHost.Create( 194var circuitHost = TestCircuitHost.Create(handlers: new[] { handler1.Object, handler2.Object }); 233var circuitHost = TestCircuitHost.Create( 262var circuitHost = TestCircuitHost.Create(handlers: new[] { handler.Object }, descriptors: [new ComponentDescriptor()]); 325var circuitHost = TestCircuitHost.Create(handlers: new[] { handler1.Object, handler2.Object }); 373var circuitHost = TestCircuitHost.Create(handlers: new[] { handler1.Object, handler2.Object, handler3.Object }); 401var circuitHost = TestCircuitHost.Create(); 428var circuitHost = TestCircuitHost.Create(clientProxy: client); 462var circuitHost = TestCircuitHost.Create(clientProxy: client); 489var circuitHost = TestCircuitHost.Create(clientProxy: client); 513var circuitHost = TestCircuitHost.Create(clientProxy: client); 527var circuitHost = TestCircuitHost.Create( 549var circuitHost = TestCircuitHost.Create( 575var circuitHost = TestCircuitHost.Create( 602var circuitHost = TestCircuitHost.Create( 640var circuitHost = TestCircuitHost.Create( 677var circuitHost = TestCircuitHost.Create( 696private async Task AddComponentAsync<TComponent>(CircuitHost circuitHost, int ssrComponentId, Dictionary<string, object> parameters = null, string componentKey = "") 713private async Task UpdateComponentAsync<TComponent>(CircuitHost circuitHost, int ssrComponentId, Dictionary<string, object> parameters = null, string componentKey = "") 729private async Task RemoveComponentAsync(CircuitHost circuitHost, int ssrComponentId)
Circuits\CircuitPersistenceManagerTest.cs (7)
47var circuitHost = await CreateCircuitHostAsync( 104var circuitHost = await CreateCircuitHostAsync( 173var circuitHost = await CreateCircuitHostAsync( 237var circuitHost = await CreateCircuitHostAsync( 396private async Task<CircuitHost> CreateCircuitHostAsync( 442var logger = NullLoggerFactory.Instance.CreateLogger<CircuitHost>(); 444var circuitHost = new CircuitHost(
Circuits\CircuitRegistryTest.cs (35)
25var circuitHost = TestCircuitHost.Create(); 31var actual = Assert.Single(registry.ConnectedCircuits.Values); 42var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId()); 49var result = await registry.ConnectAsync(circuitHost.CircuitId, newClient, newConnectionId, default); 56var actual = Assert.Single(registry.ConnectedCircuits.Values); 67var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId()); 74var result = await registry.ConnectAsync(circuitHost.CircuitId, newClient, newConnectionId, default); 81var actual = Assert.Single(registry.ConnectedCircuits.Values); 93var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId(), handlers: new[] { handler.Object }); 100var result = await registry.ConnectAsync(circuitHost.CircuitId, newClient, newConnectionId, default); 117var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId(), handlers: new[] { handler.Object }); 124var result = await registry.ConnectAsync(circuitHost.CircuitId, newClient, newConnectionId, default); 142var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId(), handlers: new[] { handler.Object }); 149var result = await registry.ConnectAsync(circuitHost.CircuitId, newClient, newConnectionId, default); 163var circuitHost = TestCircuitHost.Create(); 180var circuitHost = TestCircuitHost.Create(handlers: new[] { handler.Object }); 199var circuitHost = TestCircuitHost.Create(handlers: new[] { handler.Object }); 218var circuitHost = TestCircuitHost.Create(handlers: new[] { handler.Object }); 240var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId()); 263var actual = Assert.Single(registry.ConnectedCircuits.Values); 297var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId(), serviceProvider.CreateAsyncScope()); 349var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId(), serviceProvider.CreateAsyncScope()); 388var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId()); 402var actual = Assert.Single(registry.ConnectedCircuits.Values); 426var circuitHost = TestCircuitHost.Create(); 453var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId()); 462Assert.True(registry.ConnectedCircuits.TryGetValue(circuitHost.CircuitId, out var cacheValue)); 474var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId()); 507var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId(), scope); 535var connectResult = await connectTask; 550var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId()); 559Assert.True(registry.ConnectedCircuits.TryGetValue(circuitHost.CircuitId, out var connectedCircuit)); 585protected override (CircuitHost, bool) ConnectCore(CircuitId circuitId, ISingleClientProxy clientProxy, string connectionId) 595protected override bool DisconnectCore(CircuitHost circuitHost, string connectionId) 607internal override Task PauseCore(CircuitHost circuitHost, string connectionId)
Circuits\ComponentHubTest.cs (11)
152CircuitHost lastCircuit = null; 153handleRegistryMock.Setup(m => m.SetCircuit(It.IsAny<IDictionary<object, object>>(), It.IsAny<object>(), It.IsAny<CircuitHost>())) 154.Callback<IDictionary<object, object>, object, CircuitHost>((circuitHandles, circuitKey, circuitHost) => 257CircuitHost lastCircuit = null; 258handleRegistryMock.Setup(m => m.SetCircuit(It.IsAny<IDictionary<object, object>>(), It.IsAny<object>(), It.IsAny<CircuitHost>())) 259.Callback<IDictionary<object, object>, object, CircuitHost>((circuitHandles, circuitKey, circuitHost) => 336private CircuitHost _circuitHost; 344public CircuitHost GetCircuit(IDictionary<object, object> circuitHandles, object circuitKey) 353public void SetCircuit(IDictionary<object, object> circuitHandles, object circuitKey, CircuitHost circuitHost) 407public ValueTask<CircuitHost> CreateCircuitHostAsync( 419var circuitHost = TestCircuitHost.Create(
Circuits\TestCircuitHost.cs (2)
25public static CircuitHost Create( 77NullLogger<CircuitHost>.Instance);