76 instantiations of AppHostSnapshot
Aspire.Tray.Tests (76)
src\Aspire.Tray\Common\CliAppHostClient.cs (1)
45var latest = new AppHostSnapshot([], DiscoveryState.Connecting);
src\Aspire.Tray\Common\CliProtocol.cs (1)
63return new(hosts.OrderBy(host => host.AppHostPath, StringComparer.Ordinal)
src\Aspire.Tray\Common\TrayController.cs (1)
21private AppHostSnapshot _snapshot = new([], DiscoveryState.Connecting);
TrayControllerPinPruningTests.cs (15)
36await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 59await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 61await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Disconnected)); 66await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 88await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 97await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Disconnected)); 99await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 117await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 144await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 167await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 177await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 180await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 182await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 206await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 273await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live));
TrayControllerPreferencesTests.cs (5)
148await client.PublishAndWaitAsync(controller, new(hosts, DiscoveryState.Live)); 149await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 180await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 197await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 200await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live));
TrayControllerSavedStateTests.cs (42)
26await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 71await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 77await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Disconnected)); 85await client.PublishAndWaitAsync(controller, new([running], DiscoveryState.Live)); 107await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 120await client.PublishAndWaitAsync(controller, new([Host(42) with { AppHostPath = path }], DiscoveryState.Live)); 136await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 141await client.PublishAndWaitAsync(controller, new([Host(42) with { AppHostPath = path }], DiscoveryState.Live)); 142await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 165await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 203await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 219await client.PublishAndWaitAsync(controller, new([first], DiscoveryState.Live)); 236await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 252await client.PublishAndWaitAsync(controller, new([replacement], DiscoveryState.Live)); 260await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 276await client.PublishAndWaitAsync(controller, new([first, second], DiscoveryState.Live)); 282await client.PublishAndWaitAsync(controller, new([second], DiscoveryState.Live)); 284await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 301await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 308await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 309await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Disconnected)); 310await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 313await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 320await client.PublishAndWaitAsync(controller, new([replacement], DiscoveryState.Live)); 322await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 340await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 351await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 366await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 378await client.PublishAndWaitAsync(controller, new([running], DiscoveryState.Live)); 398await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 419await client.PublishAndWaitAsync(controller, new([running], DiscoveryState.Live)); 437await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 459await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 461await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Disconnected)); 482await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 513await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 532await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 554await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 558await client.PublishAndWaitAsync(controller, new([replacement], DiscoveryState.Live)); 560await client.PublishAndWaitAsync(controller, new([replacement], DiscoveryState.Disconnected)); 563await client.PublishAndWaitAsync(controller, new([replacement], DiscoveryState.Incompatible)); 577await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live));
TrayControllerTests.cs (11)
21client.Publish(new([], DiscoveryState.Live)); 24client.Publish(new([], DiscoveryState.Disconnected)); 37client.Publish(new([first, second], DiscoveryState.Live)); 62client.Publish(new([], DiscoveryState.Live)); 75client.Publish(new([first, second], DiscoveryState.Live)); 80client.Publish(new([second, updated], DiscoveryState.Live)); 86client.Publish(new([replacement, second], DiscoveryState.Live)); 104client.Publish(new([known, unknown], DiscoveryState.Live)); 114client.Publish(new([known, unknown], DiscoveryState.Disconnected)); 134client.Publish(new([first, second], DiscoveryState.Live)); 163client.Publish(new([first, second], DiscoveryState.Live));
21 references to AppHostSnapshot
Aspire.Tray.Tests (21)
CliProtocolTests.cs (5)
14var snapshot = Parse("""{"version":1,"type":"snapshot","appHosts":[]}"""); 22var first = Parse(Snapshot(Host(42), Host(43))); 23var second = Parse(Snapshot(Host(43) with { DashboardUrl = "https://localhost:5678/" })); 101var snapshot = Parse("""{"version":1,"type":"snapshot","appHosts":[],"futureField":true}"""); 189private static AppHostSnapshot Parse(string json) => CliProtocol.ReadSnapshot(CliProtocol.ReadWatchMessage(json));
Helpers\TestAppHostClient.cs (6)
12private readonly Channel<AppHostSnapshot> _snapshots = Channel.CreateUnbounded<AppHostSnapshot>(); 23public void Publish(AppHostSnapshot snapshot) 31public async IAsyncEnumerable<AppHostSnapshot> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken) 35await foreach (var snapshot in _snapshots.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 98public async Task PublishAndWaitAsync(TrayController controller, AppHostSnapshot snapshot)
src\Aspire.Tray\Common\CliAppHostClient.cs (4)
43public async IAsyncEnumerable<AppHostSnapshot> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken) 45var latest = new AppHostSnapshot([], DiscoveryState.Connecting); 104private async IAsyncEnumerable<AppHostSnapshot> WatchConnectionAsync(Action onHealthyConnection, [EnumeratorCancellation] CancellationToken cancellationToken) 123var snapshot = CliProtocol.ReadSnapshot(message);
src\Aspire.Tray\Common\CliProtocol.cs (1)
30public static AppHostSnapshot ReadSnapshot(TrayWatchMessage message)
src\Aspire.Tray\Common\IAppHostClient.cs (1)
8IAsyncEnumerable<AppHostSnapshot> WatchAsync(CancellationToken cancellationToken);
src\Aspire.Tray\Common\TrayController.cs (4)
21private AppHostSnapshot _snapshot = new([], DiscoveryState.Connecting); 301await foreach (var snapshot in _client.WatchAsync(_shutdown.Token).ConfigureAwait(false)) 325AppHostSnapshot snapshot; 333private void SetSnapshot(AppHostSnapshot snapshot)