Implemented interface member:
method
WatchAsync<T>
Aspire.Hosting.Dcp.IKubernetesService.WatchAsync<T>(System.String, System.Threading.CancellationToken)
17 references to WatchAsync
Aspire.Hosting.Tests (17)
Dcp\KubernetesServiceTests.cs (17)
106await using var enumerator = service.WatchAsync<Container>(namespaceParameter, watchCts.Token).GetAsyncEnumerator(); 186await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 273await using var enumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator(); 339await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 383await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 437await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 485await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 541await foreach (var (_, container) in service.WatchAsync<Container>(cancellationToken: token)) 591await foreach (var (_, container) in service.WatchAsync<Container>(cancellationToken: token)) 628await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 681await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 762await foreach (var (_, container) in service.WatchAsync<Container>(cancellationToken: token)) 822await foreach (var _ in service.WatchAsync<Container>(cancellationToken: token)) 2033await using var watchEnumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator(); 2065await using var watchEnumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator(); 2119await using var watchEnumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator(); 2191await using var watchEnumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator();