1 instantiation of ResourceSnapshotChange
Aspire.Hosting (1)
Dashboard\ResourcePublisher.cs (1)
106
await channel.Writer.WriteAsync(
new
(changeType, snapshot), cancellationToken).ConfigureAwait(false);
7 references to ResourceSnapshotChange
Aspire.Hosting (7)
Dashboard\DashboardService.cs (2)
80
foreach (
var
update in batch)
94
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);