2 implementations of WatchAsync
Aspire.Hosting (1)
Dcp\KubernetesService.cs (1)
255public async IAsyncEnumerable<(WatchEventType, T)> WatchAsync<T>(
Aspire.Hosting.Tests (1)
Dcp\TestKubernetesService.cs (1)
132public async IAsyncEnumerable<(WatchEventType, T)> WatchAsync<T>(string? namespaceParameter = null, [EnumeratorCancellation] CancellationToken cancellationToken = default) where T : CustomResource
6 references to WatchAsync
Aspire.Hosting (2)
Dcp\DcpExecutor.cs (2)
323await foreach (var (eventType, resource) in _kubernetesService.WatchAsync<T>(cancellationToken: pipelineCancellationToken).ConfigureAwait<(global::k8s.WatchEventType, T)>(false)) 713var serviceChangeEnumerator = _kubernetesService.WatchAsync<Service>(cancellationToken: attemptCancellationToken);
Aspire.Hosting.Tests (4)
DistributedApplicationTests.cs (2)
973await foreach (var resource in s.WatchAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)) 987await foreach (var resource in s.WatchAsync<Executable>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout))
Helpers\KubernetesHelper.cs (2)
15await foreach (var (_, r) in kubernetes.WatchAsync<T>(cancellationToken: cancellationToken)) 30await foreach (var (_, r) in kubernetes.WatchAsync<T>(cancellationToken: cancellationToken))