1 instantiation of LogSubscriber
Aspire.Hosting (1)
ApplicationModel\ResourceLoggerService.cs (1)
237
channel.Writer.TryWrite(
new
(name, hasSubscribers));
10 references to LogSubscriber
Aspire.Hosting (4)
ApplicationModel\ResourceLoggerService.cs (3)
223
public async IAsyncEnumerable<
LogSubscriber
> WatchAnySubscribersAsync([EnumeratorCancellation] CancellationToken cancellationToken = default)
225
var channel = Channel.CreateUnbounded<
LogSubscriber
>();
248
await foreach (
var
entry in channel.Reader.ReadAllAsync(linkedCts.Token).ConfigureAwait(false))
Dcp\DcpExecutor.cs (1)
324
await foreach (
var
subscribers in _loggerService.WatchAnySubscribersAsync(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Testing.Tests (1)
ResourceLoggerForwarderServiceTests.cs (1)
63
await foreach (
var
sub in resourceLoggerService.WatchAnySubscribersAsync(hostApplicationLifetime.ApplicationStopping))
Aspire.Hosting.Tests (5)
Dashboard\DashboardLifecycleHookTests.cs (1)
51
await foreach (
var
item in resourceLoggerService.WatchAnySubscribersAsync().DefaultTimeout())
Dashboard\DashboardResourceTests.cs (1)
545
await foreach (
var
sub in resourceLoggerService.WatchAnySubscribersAsync())
ResourceLoggerServiceTests.cs (3)
385
var subscribers = new List<
LogSubscriber
>();
389
await foreach (
var
sub in service.WatchAnySubscribersAsync())
439
await foreach (
var
sub in service.WatchAnySubscribersAsync())