1 instantiation of LogSubscriber
Aspire.Hosting (1)
ApplicationModel\ResourceLoggerService.cs (1)
231
channel.Writer.TryWrite(
new
(name, hasSubscribers));
8 references to LogSubscriber
Aspire.Hosting (4)
ApplicationModel\ResourceLoggerService.cs (3)
221
public async IAsyncEnumerable<
LogSubscriber
> WatchAnySubscribersAsync([EnumeratorCancellation] CancellationToken cancellationToken = default)
223
var channel = Channel.CreateUnbounded<
LogSubscriber
>();
239
await foreach (
var
entry in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Dcp\DcpExecutor.cs (1)
235
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 (3)
Dashboard\DashboardLifecycleHookTests.cs (1)
53
await foreach (
var
item in resourceLoggerService.WatchAnySubscribersAsync().DefaultTimeout())
Dashboard\DashboardResourceTests.cs (1)
460
await foreach (
var
sub in resourceLoggerService.WatchAnySubscribersAsync())
ResourceLoggerServiceTests.cs (1)
318
await foreach (
var
sub in service.WatchAnySubscribersAsync())