2 implementations of WatchAsync
Aspire.Hosting (1)
Dcp\KubernetesService.cs (1)
259
public async IAsyncEnumerable<(WatchEventType, T)>
WatchAsync
<T>(
Aspire.Hosting.Tests (1)
Dcp\TestKubernetesService.cs (1)
281
public async IAsyncEnumerable<(WatchEventType, T)>
WatchAsync
<T>(string? namespaceParameter = null, [EnumeratorCancellation] CancellationToken cancellationToken = default) where T : CustomResource, IKubernetesStaticMetadata
6 references to WatchAsync
Aspire.Hosting (2)
Dcp\DcpExecutor.cs (1)
419
var changeEnumerator = _kubernetesService.
WatchAsync
<TDcpResource>(cancellationToken: attemptCancellationToken);
Dcp\DcpResourceWatcher.cs (1)
206
await foreach (var (eventType, resource) in _kubernetesService.
WatchAsync
<T>(cancellationToken: pipelineCancellationToken).ConfigureAwait<(global::k8s.WatchEventType, T)>(false))
Aspire.Hosting.Tests (2)
DistributedApplicationTests.cs (2)
1640
await foreach (var resource in s.
WatchAsync
<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout))
1654
await foreach (var resource in s.
WatchAsync
<Executable>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout))
Aspire.Hosting.TestUtilities (2)
Helpers\KubernetesHelper.cs (2)
15
await foreach (var (_, r) in kubernetes.
WatchAsync
<T>(cancellationToken: cancellationToken))
30
await foreach (var (_, r) in kubernetes.
WatchAsync
<T>(cancellationToken: cancellationToken))