31 instantiations of ResourceViewModelChange
Aspire.Dashboard (7)
ServiceClient\DashboardClient.cs (3)
649changes.Add(new(ResourceViewModelChangeType.Upsert, viewModel)); 669changes.Add(new(ResourceViewModelChangeType.Upsert, viewModel)); 676changes.Add(new(ResourceViewModelChangeType.Delete, removed));
ServiceClient\SqliteResourceRepository.cs (4)
200changes.Add(new ResourceViewModelChange(ResourceViewModelChangeType.Delete, viewModel)); 214changes.Add(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, viewModel)); 265viewModelChanges.Add(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, viewModel)); 270viewModelChanges.Add(new ResourceViewModelChange(ResourceViewModelChangeType.Delete, removed));
Aspire.Dashboard.Components.Tests (19)
Controls\TerminalDisconnectedBannerTests.cs (7)
43await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, resource)]); 49await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Delete, resource)]); 125new(ResourceViewModelChangeType.Upsert, updated), 126new(ResourceViewModelChangeType.Upsert, ModelTestHelpers.CreateResource(resourceName: "shell-other", displayName: "shell"))]); 168await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, ModelTestHelpers.CreateResource(resourceName: "shell", 172await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, ModelTestHelpers.CreateResource(resourceName: "shell", 177await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Delete, resource)]);
Layout\MainLayoutResourceTerminalsTests.cs (4)
118await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, resource)]); 121await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, ModelTestHelpers.CreateResource("shell"))]); 124await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, resource)]); 127await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Delete, resource)]);
Pages\ConsoleLogsTests.cs (1)
839new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, testResource)
Pages\ResourcesTests.cs (3)
296new ResourceViewModelChange( 637await channel.Writer.WriteAsync([new ResourceViewModelChange( 1029new ResourceViewModelChange(
Pages\TerminalsTests.cs (4)
503await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, 510await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Delete, last)]); 524await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, ModelTestHelpers.CreateResource("first"))]); 598await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, TerminalSetupHelpers.CreateTerminalResource("added"))]);
Aspire.Dashboard.Tests (5)
ResourceOutgoingPeerResolverTests.cs (5)
310await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8080, state: KnownResourceState.Starting))); 320await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Starting))); 329await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Running))); 414await sourceChannel.Writer.WriteAsync([new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test", state: KnownResourceState.Starting))]); 415await sourceChannel.Writer.WriteAsync([new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test", state: KnownResourceState.Running))]);
108 references to ResourceViewModelChange
Aspire.Dashboard (16)
Components\Pages\Terminals.razor.cs (1)
132private async Task WatchResourcesAsync(IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> updates, CancellationToken cancellationToken)
ServiceClient\DashboardClient.cs (5)
73private ImmutableHashSet<Channel<IReadOnlyList<ResourceViewModelChange>>> _outgoingResourceChannels = []; 614List<ResourceViewModelChange>? changes = null; 615ImmutableHashSet<Channel<IReadOnlyList<ResourceViewModelChange>>> resourceChannels = []; 916var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>( 928async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> StreamUpdatesAsync([EnumeratorCancellation] CancellationToken enumeratorCancellationToken = default)
ServiceClient\IDashboardClient.cs (1)
122IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> Subscription);
ServiceClient\SqliteResourceRepository.cs (9)
27private ImmutableHashSet<Channel<IReadOnlyList<ResourceViewModelChange>>> _resourceChannels = []; 73var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(new UnboundedChannelOptions 183List<ResourceViewModelChange> changes = []; 236List<ResourceViewModelChange> viewModelChanges = []; 478private async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> ReadResourceUpdatesAsync( 479Channel<IReadOnlyList<ResourceViewModelChange>> channel, 498private void PublishResourceChanges(IReadOnlyList<ResourceViewModelChange> changes) 505Channel<IReadOnlyList<ResourceViewModelChange>>[] channels; 532Channel<IReadOnlyList<ResourceViewModelChange>>[] resourceChannels;
Aspire.Dashboard.Components.Tests (76)
Controls\ResourceActionsTests.cs (4)
36resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>, 77resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 100resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 116resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>);
Controls\TerminalDisconnectedBannerTests.cs (5)
30var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 67resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(), 104var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 147resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 159var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Controls\TerminalViewTests.cs (1)
600resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>());
Dialogs\ManageDataDialogTests.cs (2)
42var resourcesChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 256var resourcesChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Layout\MainLayoutResourceTerminalsTests.cs (3)
31resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()) 58resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()) 104var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Layout\MainLayoutTerminalTests.cs (3)
38resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 91resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()) 176resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>());
Pages\ConsoleLogsTerminalTests.cs (1)
30resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(),
Pages\ConsoleLogsTests.cs (19)
42var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 92var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 181var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 270var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 322var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 370var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 414resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>, 432var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 473var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 499var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 548var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 597var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 662var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 700var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 755var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 796var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 872resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>, 905var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 964var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Pages\ResourcesTests.cs (24)
56], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 155var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 180var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 230resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>, 262var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 361var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 414var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 543var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 657var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [resource], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 703var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 731var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 759var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 790var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 911resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1006var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1139var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1166var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1195var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1225var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1257var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1339var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1401var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1445var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1484resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>,
Pages\TerminalsTests.cs (8)
52resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 92resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 116resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()) 151resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 467resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 496var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 592var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 659resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>());
Shared\ResourceSetupHelpers.cs (1)
72context.Services.AddSingleton<IDashboardClient>(dashboardClient ?? new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>));
Shared\TerminalSetupHelpers.cs (1)
29resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(),
tests\Shared\TestDashboardClient.cs (4)
19private readonly Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? _resourceChannelProvider; 60Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? resourceChannelProvider = null, 215async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> BuildSubscription(Channel<IReadOnlyList<ResourceViewModelChange>> channel, [EnumeratorCancellation] CancellationToken cancellationToken)
Aspire.Dashboard.Playwright.Tests (5)
tests\Aspire.Dashboard.Tests\Shared\MockDashboardClient.cs (1)
86private static async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> Test()
tests\Shared\TestDashboardClient.cs (4)
19private readonly Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? _resourceChannelProvider; 60Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? resourceChannelProvider = null, 215async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> BuildSubscription(Channel<IReadOnlyList<ResourceViewModelChange>> channel, [EnumeratorCancellation] CancellationToken cancellationToken)
Aspire.Dashboard.Tests (11)
ResourceOutgoingPeerResolverTests.cs (6)
285var sourceChannel = Channel.CreateUnbounded<ResourceViewModelChange>(); 339async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> GetChanges([EnumeratorCancellation] CancellationToken cancellationToken = default) 341await foreach (var item in sourceChannel.Reader.ReadAllAsync(cancellationToken)) 364var sourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 383var sourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 400var sourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Shared\MockDashboardClient.cs (1)
86private static async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> Test()
tests\Shared\TestDashboardClient.cs (4)
19private readonly Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? _resourceChannelProvider; 60Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? resourceChannelProvider = null, 215async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> BuildSubscription(Channel<IReadOnlyList<ResourceViewModelChange>> channel, [EnumeratorCancellation] CancellationToken cancellationToken)