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