Implemented interface member:
method
WatchAsync<T>
Aspire.Hosting.Dcp.IKubernetesService.WatchAsync<T>(System.String, System.Threading.CancellationToken)
18 references to WatchAsync
Aspire.Hosting.Tests (18)
Dcp\KubernetesServiceTests.cs (18)
147await using var enumerator = service.WatchAsync<Container>(namespaceParameter, watchCts.Token).GetAsyncEnumerator(); 227await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 314await using var enumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator(); 380await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 424await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 478await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 526await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 593await foreach (var (_, container) in service.WatchAsync<Container>(cancellationToken: token)) 652await foreach (var (_, container) in service.WatchAsync<Container>(cancellationToken: token)) 702await foreach (var (_, container) in service.WatchAsync<Container>(cancellationToken: token)) 739await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 792await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 873await foreach (var (_, container) in service.WatchAsync<Container>(cancellationToken: token)) 933await foreach (var _ in service.WatchAsync<Container>(cancellationToken: token)) 2144await using var watchEnumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator(); 2176await using var watchEnumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator(); 2230await using var watchEnumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator(); 2302await using var watchEnumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator();