15 references to WatchAsync
Aspire.Hosting (6)
ApplicationModel\ResourceLoggerService.cs (2)
184
return CombineMultipleAsync(resourceNames,
WatchAsync
);
188
return
WatchAsync
(resourceNames[0]);
Dashboard\DashboardEventHandlers.cs (1)
769
await foreach (var batch in resourceLoggerService.
WatchAsync
(dashboardResourceId).WithCancellation(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardServiceData.cs (1)
127
var sequence = _resourceLoggerService.
WatchAsync
(resourceName);
Exec\ExecResourceManager.cs (1)
113
await foreach (var logs in _resourceLoggerService.
WatchAsync
(dcpExecResourceName).WithCancellation(cancellationToken).ConfigureAwait(false))
ResourceLoggerForwarderService.cs (1)
67
await foreach (var logEvent in resourceLoggerService.
WatchAsync
(resourceId).WithCancellation(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Testing.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
162
await foreach (var logEvent in resourceLoggerService.
WatchAsync
(resourceId).WithCancellation(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Hosting.Tests (7)
Dcp\DcpExecutorTests.cs (4)
631
var watchLogs = resourceLoggerService.
WatchAsync
(exeResource.Metadata.Name);
734
var watchLogs1 = resourceLoggerService.
WatchAsync
(exeResource.Metadata.Name);
756
var watchLogs2 = resourceLoggerService.
WatchAsync
(exeResource.Metadata.Name);
814
var watchLogs = resourceLoggerService.
WatchAsync
(exeResource.Metadata.Name);
ResourceLoggerServiceTests.cs (2)
355
await foreach (var batch in service.
WatchAsync
("nonexistent"))
407
var logWatchEnumerator = service.
WatchAsync
("testResource").GetAsyncEnumerator();
Utils\LoggerNotificationExtensions.cs (1)
162
await foreach (var logEvent in resourceLoggerService.
WatchAsync
(resourceId).WithCancellation(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
162
await foreach (var logEvent in resourceLoggerService.
WatchAsync
(resourceId).WithCancellation(cancellationTokenSource.Token).ConfigureAwait(false))