1 instantiation of ResourceSnapshotChange
Aspire.Hosting (1)
Dashboard\ResourcePublisher.cs (1)
106
await channel.Writer.WriteAsync(
new
(changeType, snapshot), cancellationToken).ConfigureAwait(false);
11 references to ResourceSnapshotChange
Aspire.Hosting (7)
Dashboard\DashboardService.cs (2)
244
foreach (
var
update in batch)
258
throw new FormatException($"Unexpected {nameof(
ResourceSnapshotChange
)} type: {update.ChangeType}");
Dashboard\ResourcePublisher.cs (5)
23
private ImmutableHashSet<Channel<
ResourceSnapshotChange
>> _outgoingChannels = [];
49
var channel = Channel.CreateUnbounded<
ResourceSnapshotChange
>(
58
async IAsyncEnumerable<IReadOnlyList<
ResourceSnapshotChange
>> StreamUpdates([EnumeratorCancellation] CancellationToken enumeratorCancellationToken = default)
86
ImmutableHashSet<Channel<
ResourceSnapshotChange
>> channels;
113
IAsyncEnumerable<IReadOnlyList<
ResourceSnapshotChange
>> Subscription);
Aspire.Hosting.Tests (4)
Dashboard\ResourcePublisherTests.cs (4)
35
var tcs = new TaskCompletionSource<IReadOnlyList<
ResourceSnapshotChange
>>(TaskCreationOptions.RunContinuationsAsynchronously);
47
var
change = Assert.Single(await tcs.Task.DefaultTimeout());
96
var
v1 = Assert.Single(enumerator1.Current);
97
var
v2 = Assert.Single(enumerator2.Current);