16 references to WatchAsync
Aspire.Hosting.Azure.Tests (1)
AzureBicepProvisionerTests.cs (1)
1751await using var logEnumerator = loggerService.WatchAsync(resource).GetAsyncEnumerator(cts.Token);
Aspire.Hosting.EntityFrameworkCore (1)
EFCoreOperationExecutor.cs (1)
300var logTask = CaptureLogsAsync(loggerService.WatchAsync(_toolResource), _logger, dataBuilder, logCancellation.Token);
Aspire.Hosting.Testing.Tests (1)
tests\Shared\ConsoleLogging\ConsoleLoggingTestHelpers.cs (1)
35var watchEnumerable = service.WatchAsync(resource);
Aspire.Hosting.Tests (13)
Lifecycle\TerminalHostFailureDiagnosticServiceTests.cs (2)
277await foreach (var batch in loggers.WatchAsync(host).WithCancellation(cts?.Token ?? CancellationToken.None)) 300await foreach (var batch in loggers.WatchAsync(host).WithCancellation(timeoutCts.Token))
ResourceLoggerServiceTests.cs (10)
25var logsEnumerator1 = service.WatchAsync(testResource).GetAsyncEnumerator(); 46var logsEnumerator2 = service.WatchAsync(testResource).GetAsyncEnumerator(); 106var logsEnumerator1 = service.WatchAsync(testResource).GetAsyncEnumerator(); 127var logsEnumerator2 = service.WatchAsync(testResource).GetAsyncEnumerator(); 140var logsEnumerator3 = service.WatchAsync(testResource).GetAsyncEnumerator(); 162var logsEnumerator1 = service.WatchAsync(testResource).GetAsyncEnumerator(); 185var logsEnumerator2 = service.WatchAsync(testResource).GetAsyncEnumerator(); 203var logsEnumerator3 = service.WatchAsync(testResource).GetAsyncEnumerator(); 227var logsEnumerator = service.WatchAsync(testResource).GetAsyncEnumerator(); 684await foreach (var batch in service.WatchAsync(testResource))
tests\Shared\ConsoleLogging\ConsoleLoggingTestHelpers.cs (1)
35var watchEnumerable = service.WatchAsync(resource);