2 types derived from TerminalUpdate
Aspire.Hosting (2)
ApplicationModel\TerminalChange.cs (2)
42
internal sealed record TerminalChange(TerminalChangeType ChangeType, TerminalDescriptor Terminal) :
TerminalUpdate
;
49
string? ActivatedTerminalId) :
TerminalUpdate
;
14 references to TerminalUpdate
Aspire.Hosting (8)
ApplicationModel\TerminalService.cs (7)
55
private ImmutableHashSet<Channel<
TerminalUpdate
>> _outgoingChannels = [];
306
var channel = Channel.CreateBounded<
TerminalUpdate
>(new BoundedChannelOptions(_dockUpdateBufferCapacity)
334
async IAsyncEnumerable<
TerminalUpdate
> StreamChanges([EnumeratorCancellation] CancellationToken cancellationToken = default)
340
TerminalUpdate
? change;
368
private void Unsubscribe(Channel<
TerminalUpdate
> channel)
444
while (channel.Reader.TryRead(out
var
pending))
540
IAsyncEnumerable<
TerminalUpdate
> Subscription) : IDisposable
Dashboard\DashboardService.cs (1)
703
await foreach (
var
update in subscription.Subscription.WithCancellation(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Tests (5)
Terminals\TerminalServiceTests.cs (5)
581
await foreach (
var
update in subscription.Subscription)
872
var changes = new List<
TerminalUpdate
>();
873
await foreach (
var
change in subscription.Subscription)
1065
private static ImmutableHashSet<Channel<
TerminalUpdate
>> GetOutgoingChannels(TerminalService service)
1070
return (ImmutableHashSet<Channel<
TerminalUpdate
>>)field.GetValue(service)!;
Aspire.Hosting.TestUtilities (1)
Utils\TerminalCommandTestHelpers.cs (1)
32
await foreach (
var
update in subscription.Subscription.WithCancellation(cancellationToken))