2 instantiations of LogSubscriber
Aspire.Hosting (1)
ApplicationModel\ResourceLoggerService.cs (1)
252
channel.Writer.TryWrite(
new
(name, hasSubscribers));
Aspire.Hosting.Tests (1)
ResourceLoggerServiceTests.cs (1)
826
Assert.Equal(new
LogSubscriber
("myResource", AnySubscribers: true), lateWatcher.Current);
14 references to LogSubscriber
Aspire.Hosting (4)
ApplicationModel\ResourceLoggerService.cs (3)
238
public async IAsyncEnumerable<
LogSubscriber
> WatchAnySubscribersAsync([EnumeratorCancellation] CancellationToken cancellationToken = default)
240
var channel = Channel.CreateUnbounded<
LogSubscriber
>();
263
await foreach (
var
entry in channel.Reader.ReadAllAsync(linkedCts.Token).ConfigureAwait(false))
Dcp\DcpResourceWatcher.cs (1)
167
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 (6)
Dashboard\DashboardResourceTests.cs (1)
732
await foreach (
var
sub in resourceLoggerService.WatchAnySubscribersAsync())
ResourceLoggerServiceTests.cs (4)
748
var subscribers = new List<
LogSubscriber
>();
752
await foreach (
var
sub in service.WatchAnySubscribersAsync())
797
IAsyncEnumerator<
LogSubscriber
>? lateWatcher = null;
866
await foreach (
var
sub in service.WatchAnySubscribersAsync())
tests\Shared\ConsoleLogging\ConsoleLoggingTestHelpers.cs (1)
17
await foreach (
var
subscriber in service.WatchAnySubscribersAsync())