AppHostSnapshot

4 instantiations of AppHostSnapshot

aspire-tray (4)

NativeSmokeHarness.cs (1)

365=> _client.Publish(new(hosts, discovery));

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);

15 references to AppHostSnapshot

aspire-tray (15)

NativeSmokeHarness.cs (5)

419private readonly Channel<AppHostSnapshot> _snapshots = Channel.CreateUnbounded<AppHostSnapshot>( 427internal void Publish(AppHostSnapshot snapshot) 430public async IAsyncEnumerable<AppHostSnapshot> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken) 432await foreach (var snapshot in _snapshots.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

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)