1 instantiation of LogSubscriber
Aspire.Hosting (1)
ApplicationModel\ResourceLoggerService.cs (1)
240
channel.Writer.TryWrite(
new
(name, hasSubscribers));
13 references to LogSubscriber
Aspire.Hosting (4)
ApplicationModel\ResourceLoggerService.cs (3)
226
public async IAsyncEnumerable<
LogSubscriber
> WatchAnySubscribersAsync([EnumeratorCancellation] CancellationToken cancellationToken = default)
228
var channel = Channel.CreateUnbounded<
LogSubscriber
>();
251
await foreach (
var
entry in channel.Reader.ReadAllAsync(linkedCts.Token).ConfigureAwait(false))
Dcp\DcpResourceWatcher.cs (1)
138
await foreach (
var
subscribers in _loggerService.WatchAnySubscribersAsync(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Browsers.Tests (1)
ConsoleLoggingTestHelpers.cs (1)
20
await foreach (
var
subscriber in service.WatchAnySubscribersAsync())
Aspire.Hosting.Testing.Tests (3)
ResourceLoggerForwarderServiceTests.cs (2)
42
await foreach (
var
sub in resourceLoggerService.WatchAnySubscribersAsync(hostApplicationLifetime.ApplicationStopping))
81
await foreach (
var
sub in resourceLoggerService.WatchAnySubscribersAsync(hostApplicationLifetime.ApplicationStopping))
tests\Shared\ConsoleLogging\ConsoleLoggingTestHelpers.cs (1)
17
await foreach (
var
subscriber in service.WatchAnySubscribersAsync())
Aspire.Hosting.Tests (5)
Dashboard\DashboardResourceTests.cs (1)
714
await foreach (
var
sub in resourceLoggerService.WatchAnySubscribersAsync())
ResourceLoggerServiceTests.cs (3)
748
var subscribers = new List<
LogSubscriber
>();
752
await foreach (
var
sub in service.WatchAnySubscribersAsync())
812
await foreach (
var
sub in service.WatchAnySubscribersAsync())
tests\Shared\ConsoleLogging\ConsoleLoggingTestHelpers.cs (1)
17
await foreach (
var
subscriber in service.WatchAnySubscribersAsync())