9 instantiations of ResourceViewModelChange
Aspire.Dashboard (3)
ResourceService\DashboardClient.cs (3)
343changes.Add(new(ResourceViewModelChangeType.Upsert, viewModel)); 360changes.Add(new(ResourceViewModelChangeType.Upsert, viewModel)); 367changes.Add(new(ResourceViewModelChangeType.Delete, removed));
Aspire.Dashboard.Components.Tests (3)
Pages\ConsoleLogsTests.cs (1)
341new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, testResource)
Pages\ResourcesTests.cs (2)
70new ResourceViewModelChange( 342new ResourceViewModelChange(
Aspire.Dashboard.Tests (3)
ResourceOutgoingPeerResolverTests.cs (3)
149await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8080, state: KnownResourceState.Starting))); 157await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Starting))); 165await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Running)));
26 references to ResourceViewModelChange
Aspire.Dashboard (5)
ResourceService\DashboardClient.cs (4)
54private ImmutableHashSet<Channel<IReadOnlyList<ResourceViewModelChange>>> _outgoingChannels = []; 321List<ResourceViewModelChange>? changes = null; 431var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>( 443async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> StreamUpdatesAsync([EnumeratorCancellation] CancellationToken enumeratorCancellationToken = default)
ResourceService\IDashboardClient.cs (1)
61IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> Subscription);
Aspire.Dashboard.Components.Tests (17)
Pages\ConsoleLogsTests.cs (7)
48var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 134var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 180var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 237var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 298var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 362var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 422var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Pages\ResourcesTests.cs (5)
36var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 135var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 187var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 223resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 318var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Shared\ResourceSetupHelpers.cs (1)
116context.Services.AddSingleton<IDashboardClient>(dashboardClient ?? new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>));
Shared\TestDashboardClient.cs (4)
14private readonly Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? _resourceChannelProvider; 25Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? resourceChannelProvider = null, 82async static IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> BuildSubscription(Channel<IReadOnlyList<ResourceViewModelChange>> channel, [EnumeratorCancellation] CancellationToken cancellationToken)
Aspire.Dashboard.Tests (4)
Integration\Playwright\Infrastructure\MockDashboardClient.cs (1)
47private static async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> Test()
ResourceOutgoingPeerResolverTests.cs (3)
124var sourceChannel = Channel.CreateUnbounded<ResourceViewModelChange>(); 175async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> GetChanges([EnumeratorCancellation] CancellationToken cancellationToken = default) 177await foreach (var item in sourceChannel.Reader.ReadAllAsync(cancellationToken))