6 references to CreateAsync
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 (5)
Utils\PeriodicRestartAsyncEnumerableTests.cs (5)
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)) 78.CreateAsync<int>(InnerFactory, restartInterval: TimeSpan.FromMilliseconds(100), cancellationToken: cts.Token) 125var enumerable = PeriodicRestartAsyncEnumerable.CreateAsync<int>( 194var enumerable = PeriodicRestartAsyncEnumerable.CreateAsync<int>(