77 instantiations of AppHostSnapshot
Aspire.Tray.Tests (77)
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)); 58await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 60await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Disconnected)); 65await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 87await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 96await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Disconnected)); 98await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 116await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 143await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 166await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 176await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 179await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 181await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 205await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 270await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live));
TrayControllerPreferencesTests.cs (5)
100await client.PublishAndWaitAsync(controller, new(hosts, DiscoveryState.Live)); 101await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 126await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 143await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 146await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live));
TrayControllerSavedStateTests.cs (42)
26await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 70await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 76await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Disconnected)); 84await client.PublishAndWaitAsync(controller, new([running], DiscoveryState.Live)); 105await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 117await client.PublishAndWaitAsync(controller, new([Host(42) with { AppHostPath = path }], DiscoveryState.Live)); 132await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 137await client.PublishAndWaitAsync(controller, new([Host(42) with { AppHostPath = path }], DiscoveryState.Live)); 138await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 161await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 199await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 215await client.PublishAndWaitAsync(controller, new([first], DiscoveryState.Live)); 232await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 248await client.PublishAndWaitAsync(controller, new([replacement], DiscoveryState.Live)); 256await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 272await client.PublishAndWaitAsync(controller, new([first, second], DiscoveryState.Live)); 278await client.PublishAndWaitAsync(controller, new([second], DiscoveryState.Live)); 280await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 297await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 304await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 305await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Disconnected)); 306await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 309await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 316await client.PublishAndWaitAsync(controller, new([replacement], DiscoveryState.Live)); 318await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 336await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 347await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 362await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 374await client.PublishAndWaitAsync(controller, new([running], DiscoveryState.Live)); 394await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 415await client.PublishAndWaitAsync(controller, new([running], DiscoveryState.Live)); 433await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 455await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 457await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Disconnected)); 478await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 508await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 525await client.PublishAndWaitAsync(controller, new([host], DiscoveryState.Live)); 541await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live)); 544await client.PublishAndWaitAsync(controller, new([replacement], DiscoveryState.Live)); 545await client.PublishAndWaitAsync(controller, new([replacement], DiscoveryState.Disconnected)); 547await client.PublishAndWaitAsync(controller, new([replacement], DiscoveryState.Incompatible)); 560await client.PublishAndWaitAsync(controller, new([], DiscoveryState.Live));
TrayControllerTests.cs (12)
22client.Publish(new([], DiscoveryState.Live)); 26client.Publish(new([], DiscoveryState.Disconnected)); 42client.Publish(new([], (DiscoveryState)discovery)); 56client.Publish(new([first, second], DiscoveryState.Live)); 81client.Publish(new([], DiscoveryState.Live)); 94client.Publish(new([first, second], DiscoveryState.Live)); 99client.Publish(new([second, updated], DiscoveryState.Live)); 105client.Publish(new([replacement, second], DiscoveryState.Live)); 123client.Publish(new([known, unknown], DiscoveryState.Live)); 133client.Publish(new([known, unknown], DiscoveryState.Disconnected)); 153client.Publish(new([first, second], DiscoveryState.Live)); 182client.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); 281await foreach (var snapshot in _client.WatchAsync(_shutdown.Token).ConfigureAwait(false)) 305AppHostSnapshot snapshot; 313private void SetSnapshot(AppHostSnapshot snapshot)