16 references to WatchAsync
Aspire.Hosting (7)
ApplicationModel\ResourceLoggerService.cs (2)
184
return CombineMultipleAsync(resourceNames,
WatchAsync
);
188
return
WatchAsync
(resourceNames[0]);
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
707
? resourceLoggerService.
WatchAsync
(name)
Dashboard\DashboardEventHandlers.cs (1)
793
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)
632
var watchLogs = resourceLoggerService.
WatchAsync
(exeResource.Metadata.Name);
735
var watchLogs1 = resourceLoggerService.
WatchAsync
(exeResource.Metadata.Name);
757
var watchLogs2 = resourceLoggerService.
WatchAsync
(exeResource.Metadata.Name);
815
var watchLogs = resourceLoggerService.
WatchAsync
(exeResource.Metadata.Name);
ResourceLoggerServiceTests.cs (2)
356
await foreach (var batch in service.
WatchAsync
("nonexistent"))
408
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))