9 references to PeriodicRestartAsyncEnumerable
Aspire.Hosting (1)
Dcp\KubernetesService.cs (1)
306await foreach (var item in PeriodicRestartAsyncEnumerable.CreateAsync(innerWatchFactory, restartInterval: TimeSpan.FromMinutes(5), cancellationToken: cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Tests (8)
Utils\PeriodicRestartAsyncEnumerableTests.cs (8)
23await foreach (var _ in PeriodicRestartAsyncEnumerable.CreateAsync(innerFactory, restartInterval: TimeSpan.FromSeconds(2), cancellationToken: cts.Token).ConfigureAwait(false)) 46await foreach (var _ in PeriodicRestartAsyncEnumerable.CreateAsync(innerFactory, restartInterval: TimeSpan.FromMilliseconds(100), cancellationToken: cts.Token).ConfigureAwait(false)) 77await using var enumerator = PeriodicRestartAsyncEnumerable 106await using var enumerator = PeriodicRestartAsyncEnumerable 125var enumerable = PeriodicRestartAsyncEnumerable.CreateAsync<int>( 156var enumerable = PeriodicRestartAsyncEnumerable.CreateAsync<string>( 194var enumerable = PeriodicRestartAsyncEnumerable.CreateAsync<int>( 223var enumerable = PeriodicRestartAsyncEnumerable.CreateAsync<string>(