18internal class TestCircuitHost : CircuitHost

106var circuitHost = new CircuitHost(

431var circuitHost = new CircuitHost(

11private readonly CircuitHost _circuitHost; 13internal Circuit(CircuitHost circuitHost)

41public async ValueTask<CircuitHost> CreateCircuitHostAsync( 106var circuitHost = new CircuitHost( 118_loggerFactory.CreateLogger<CircuitHost>()); 133internal static void CreatedCircuit(ILogger logger, CircuitHost circuitHost) =>

12public CircuitHost CircuitHost { get; set; }

18public CircuitHost GetCircuit(IDictionary<object, object?> circuitHandles, object circuitKey) 28public void SetCircuit(IDictionary<object, object?> circuitHandles, object circuitKey, CircuitHost circuitHost)

23public async Task PauseCircuitAsync(CircuitHost circuit, bool saveStateToClient = false, CancellationToken cancellation = default) 50internal async Task SaveStateToClient(CircuitHost circuit, PersistedCircuitState state, CancellationToken cancellation = default)

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) 319CircuitHost circuitHost, 339internal virtual Task PauseCore(CircuitHost circuitHost, string connectionId) 382CircuitHost circuitHost; 409var circuitHost = (CircuitHost)sender; 425public DisconnectedCircuitEntry(CircuitHost circuitHost, CancellationTokenSource tokenSource) 431public CircuitHost CircuitHost { get; }

10ValueTask<CircuitHost> CreateCircuitHostAsync(

10CircuitHost GetCircuit(IDictionary<object, object?> circuitHandles, object circuitKey); 12void SetCircuit(IDictionary<object, object?> circuitHandles, object circuitKey, CircuitHost circuitHost);

78var circuitHost = _circuitHandleRegistry.GetCircuit(Context.Items, CircuitKey); 89var circuitHost = _circuitHandleRegistry.GetCircuit(Context.Items, CircuitKey); 171var circuitHost = await GetActiveCircuitAsync(); 232var circuitHost = await _circuitRegistry.ConnectAsync( 296var circuitHost = _circuitHandleRegistry.GetCircuit(Context.Items, CircuitKey); 447var circuitHost = await GetActiveCircuitAsync(); 463var circuitHost = await GetActiveCircuitAsync(); 474var circuitHost = await GetActiveCircuitAsync(); 485var circuitHost = await GetActiveCircuitAsync(); 496var circuitHost = await GetActiveCircuitAsync(); 512var circuitHost = await GetActiveCircuitAsync(); 547var circuitHost = await GetActiveCircuitAsync(); 559var circuitHost = await GetActiveCircuitAsync(); 570var circuitHost = await GetActiveCircuitAsync(); 585private async ValueTask<CircuitHost> GetActiveCircuitAsync([CallerMemberName] string callSite = "") 588var circuitHost = handle?.CircuitHost;

178var testCircuitHost = TestCircuitHost.Create(circuitId); 216var circuitHost = TestCircuitHost.Create(circuitId);

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); 523private static async Task<CircuitHost> CreateConnectedCircuitHostAsync( 538var circuitHost = TestCircuitHost.Create(clientProxy: client); 561var circuitHost = await CreateConnectedCircuitHostAsync(proxy); 576var circuitHost = await CreateConnectedCircuitHostAsync(proxy); 597var circuitHost = await CreateConnectedCircuitHostAsync(proxy); 646var circuitHost = TestCircuitHost.Create(clientProxy: client, remoteRenderer: remoteRenderer); 693var circuitHost = TestCircuitHost.Create(clientProxy: client); 732var circuitHost = await CreateConnectedCircuitHostAsync(proxy); 761var circuitHost = await CreateConnectedCircuitHostAsync(proxy); 774var circuitHost = TestCircuitHost.Create(clientProxy: client); 791var circuitHost = await CreateConnectedCircuitHostAsync(initialize: false); 799var circuitHost = await CreateConnectedCircuitHostAsync(); 813var circuitHost = await CreateConnectedCircuitHostAsync(proxy); 825var circuitHost = await CreateConnectedCircuitHostAsync(); 840var circuitHost = await CreateConnectedCircuitHostAsync(proxy); 851var circuitHost = await CreateConnectedCircuitHostAsync(); 862var circuitHost = await CreateConnectedCircuitHostAsync(proxy); 876var circuitHost = TestCircuitHost.Create(clientProxy: client); 896var circuitHost = TestCircuitHost.Create(clientProxy: client); 911var circuitHost = await CreateConnectedCircuitHostAsync(); 924var circuitHost = await CreateConnectedCircuitHostAsync(); 935var circuitHost = await CreateConnectedCircuitHostAsync(); 945var hosts = new List<CircuitHost>(); 968var circuitHost = await CreateConnectedCircuitHostAsync(proxy); 982var circuitHost = await CreateConnectedCircuitHostAsync(); 990var circuitHost = await CreateConnectedCircuitHostAsync(); 1004var circuitHost = await CreateConnectedCircuitHostAsync(proxy, initialize: false); 1020var circuitHost = await CreateConnectedCircuitHostAsync(); 1031var circuitHost = await CreateConnectedCircuitHostAsync(proxy); 1042var circuitHost = TestCircuitHost.Create(clientProxy: client); 1050var circuitHost = await CreateConnectedCircuitHostAsync(); 1061var circuitHost = await CreateConnectedCircuitHostAsync(); 1072var circuitHost = TestCircuitHost.Create( 1094var circuitHost = TestCircuitHost.Create( 1120var circuitHost = TestCircuitHost.Create( 1147var circuitHost = TestCircuitHost.Create( 1185var circuitHost = TestCircuitHost.Create( 1222var circuitHost = TestCircuitHost.Create( 1246var circuitHost = TestCircuitHost.Create( 1330private async Task AddComponentAsync<TComponent>(CircuitHost circuitHost, int ssrComponentId, Dictionary<string, object> parameters = null, string componentKey = "") 1347private async Task UpdateComponentAsync<TComponent>(CircuitHost circuitHost, int ssrComponentId, Dictionary<string, object> parameters = null, string componentKey = "") 1363private async Task RemoveComponentAsync(CircuitHost circuitHost, int ssrComponentId)

47var circuitHost = await CreateCircuitHostAsync( 104var circuitHost = await CreateCircuitHostAsync( 173var circuitHost = await CreateCircuitHostAsync( 237var circuitHost = await CreateCircuitHostAsync( 382private async Task<CircuitHost> CreateCircuitHostAsync( 429var logger = NullLoggerFactory.Instance.CreateLogger<CircuitHost>(); 431var circuitHost = new CircuitHost(

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()); 393var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId()); 407var actual = Assert.Single(registry.ConnectedCircuits.Values); 431var circuitHost = TestCircuitHost.Create(); 458var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId()); 467Assert.True(registry.ConnectedCircuits.TryGetValue(circuitHost.CircuitId, out var cacheValue)); 479var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId()); 512var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId(), scope); 540var connectResult = await connectTask; 555var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId()); 564Assert.True(registry.ConnectedCircuits.TryGetValue(circuitHost.CircuitId, out var connectedCircuit)); 574var circuitHost = TestCircuitHost.Create(circuitIdFactory.CreateCircuitId()); 585Assert.True(registry.ConnectedCircuits.TryGetValue(circuitHost.CircuitId, out var connected)); 612protected override (CircuitHost, bool) ConnectCore(CircuitId circuitId, ISingleClientProxy clientProxy, string connectionId) 622protected override bool DisconnectCore(CircuitHost circuitHost, string connectionId) 634internal override Task PauseCore(CircuitHost circuitHost, string connectionId)

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) => 255CircuitHost lastCircuit = null; 256handleRegistryMock.Setup(m => m.SetCircuit(It.IsAny<IDictionary<object, object>>(), It.IsAny<object>(), It.IsAny<CircuitHost>())) 257.Callback<IDictionary<object, object>, object, CircuitHost>((circuitHandles, circuitKey, circuitHost) => 334private CircuitHost _circuitHost; 342public CircuitHost GetCircuit(IDictionary<object, object> circuitHandles, object circuitKey) 351public void SetCircuit(IDictionary<object, object> circuitHandles, object circuitKey, CircuitHost circuitHost) 405public ValueTask<CircuitHost> CreateCircuitHostAsync( 417var circuitHost = TestCircuitHost.Create(

25public static CircuitHost Create( 80NullLogger<CircuitHost>.Instance);