GetAsyncEnumerator

Utils\EmptyAsyncEnumerable.cs (1)

19public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken cancellationToken = default)

Dcp\ResourceLogSource.cs (1)

21public async IAsyncEnumerator<LogEntryList> GetAsyncEnumerator(CancellationToken cancellationToken)

Infrastructure\AsyncEnumerableReaderTest.cs (2)

254public IAsyncEnumerator<string> GetAsyncEnumerator(CancellationToken cancellationToken = default) 259IAsyncEnumerator<object> IAsyncEnumerable<object>.GetAsyncEnumerator(CancellationToken cancellationToken)

src\Mvc\Mvc.Core\test\Infrastructure\AsyncEnumerableReaderTest.cs (2)

254public IAsyncEnumerator<string> GetAsyncEnumerator(CancellationToken cancellationToken = default) 259IAsyncEnumerator<object> IAsyncEnumerable<object>.GetAsyncEnumerator(CancellationToken cancellationToken)

src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (1)

82public IAsyncEnumerator<TResult> GetAsyncEnumerator(CancellationToken cancellationToken = default)

src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (1)

82public IAsyncEnumerator<TResult> GetAsyncEnumerator(CancellationToken cancellationToken = default)

HubConnectionHandlerTestUtils\Hubs.cs (3)

865public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken cancellationToken = default) 892public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken cancellationToken = default) 1175public IAsyncEnumerator<int> GetAsyncEnumerator(CancellationToken cancellationToken = default)

Internal\ReflectionHelperTests.cs (2)

70public IAsyncEnumerator<object> GetAsyncEnumerator(CancellationToken cancellationToken = default) 78public IAsyncEnumerator<object> GetAsyncEnumerator(CancellationToken cancellationToken = default)

AsyncCollectionAssertsTests.cs (1)

1574 public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken cancellationToken = default) => this;

Functions\AIFunctionFactoryTest.cs (1)

206public IAsyncEnumerator<int> GetAsyncEnumerator(CancellationToken cancellationToken = default) => throw new NotImplementedException();

System\Linq\Empty.cs (1)

28public IAsyncEnumerator<TResult> GetAsyncEnumerator(CancellationToken cancellationToken = default) => this;

System\Linq\OrderBy.cs (1)

216public abstract IAsyncEnumerator<TElement> GetAsyncEnumerator(CancellationToken cancellationToken);

System\Text\Json\Serialization\Converters\Collection\IAsyncEnumerableOfTConverter.cs (1)

140public async IAsyncEnumerator<TElement> GetAsyncEnumerator(CancellationToken _)

tests\Shared\AsyncTestHelpers.cs (1)

59await using var enumator = asyncEnumerable.GetAsyncEnumerator();

tests\Shared\AsyncTestHelpers.cs (1)

59await using var enumator = asyncEnumerable.GetAsyncEnumerator();

Utils\PeriodicRestartAsyncEnumerable.cs (2)

30var enumerator = enumerable.GetAsyncEnumerator(cts.Token); 86var enumerator = enumerable.GetAsyncEnumerator(cts.Token);

tests\Shared\AsyncTestHelpers.cs (1)

59await using var enumator = asyncEnumerable.GetAsyncEnumerator();

tests\Shared\AsyncTestHelpers.cs (1)

59await using var enumator = asyncEnumerable.GetAsyncEnumerator();

tests\Shared\AsyncTestHelpers.cs (1)

59await using var enumator = asyncEnumerable.GetAsyncEnumerator();

tests\Shared\AsyncTestHelpers.cs (1)

59await using var enumator = asyncEnumerable.GetAsyncEnumerator();

tests\Shared\AsyncTestHelpers.cs (1)

59await using var enumator = asyncEnumerable.GetAsyncEnumerator();

Dashboard\ResourcePublisherTests.cs (2)

91var enumerator1 = subscription1.GetAsyncEnumerator(cts.Token); 92var enumerator2 = subscription2.GetAsyncEnumerator(cts.Token);

Dcp\DcpExecutorTests.cs (3)

591var watchSubscribersEnumerator = watchSubscribers.GetAsyncEnumerator(); 593var watchLogsEnumerator = watchLogs.GetAsyncEnumerator(watchCts.Token); 688var watchSubscribersEnumerator = watchSubscribers.GetAsyncEnumerator();

Orchestrator\ParameterProcessorTests.cs (1)

183var updates = notificationService.WatchAsync().GetAsyncEnumerator();

ResourceLoggerServiceTests.cs (9)

tests\Shared\AsyncTestHelpers.cs (1)

59await using var enumator = asyncEnumerable.GetAsyncEnumerator();

tests\Shared\AsyncTestHelpers.cs (1)

59await using var enumator = asyncEnumerable.GetAsyncEnumerator();

tests\Shared\AsyncTestHelpers.cs (1)

59await using var enumator = asyncEnumerable.GetAsyncEnumerator();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)

622Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)

622Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException();

src\Shared\EventSource.Testing\TestCounterListener.cs (1)

41var values = _counters[counterName].Reader.ReadAllAsync(cancellationToken).GetAsyncEnumerator(cancellationToken);

src\Shared\EventSource.Testing\TestCounterListener.cs (1)

41var values = _counters[counterName].Reader.ReadAllAsync(cancellationToken).GetAsyncEnumerator(cancellationToken);

Infrastructure\AsyncEnumerableReaderTest.cs (1)

256return TestEnumerable().GetAsyncEnumerator(cancellationToken);

src\Mvc\Mvc.Core\test\Infrastructure\AsyncEnumerableReaderTest.cs (1)

256return TestEnumerable().GetAsyncEnumerator(cancellationToken);

src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (2)

18var enumerator = asyncEnumerable.GetAsyncEnumerator(cancellationToken); 84var enumerator = _asyncEnumerable.GetAsyncEnumerator(_cts.Token);

HubConnectionTests.cs (2)

614var enumerator = stream.GetAsyncEnumerator(); 940var enumerator = stream.GetAsyncEnumerator(cts.Token);

HubConnectionTests.Tracing.cs (1)

407var enumerator = stream.GetAsyncEnumerator();

HubConnectionTests.cs (3)

272await Assert.ThrowsAsync<TaskCanceledException>(() => result.GetAsyncEnumerator().MoveNextAsync().DefaultTimeout()); 293await using var e = asyncEnumerable.GetAsyncEnumerator(cts.Token); 324await using var e = asyncEnumerable.GetAsyncEnumerator(cts.Token);

src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (2)

18var enumerator = asyncEnumerable.GetAsyncEnumerator(cancellationToken); 84var enumerator = _asyncEnumerable.GetAsyncEnumerator(_cts.Token);

HubConnectionHandlerTestUtils\Hubs.cs (1)

867return _inner.GetAsyncEnumerator(cancellationToken);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)

622Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)

622Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)

622Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)

622Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)

622Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)

622Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)

622Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)

622Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException();

AsyncCollectionAssertsTests.cs (1)

1566 innerEnumerator = enumerable.GetAsyncEnumerator();

ChatCompletion\LoggingChatClient.cs (1)

118e = base.GetStreamingResponseAsync(messages, options, cancellationToken).GetAsyncEnumerator(cancellationToken);

ChatCompletion\OpenTelemetryChatClient.cs (1)

186var responseEnumerator = updates.GetAsyncEnumerator(cancellationToken);

SpeechToText\LoggingSpeechToTextClient.cs (1)

121e = base.GetStreamingTextAsync(audioSpeechStream, options, cancellationToken).GetAsyncEnumerator(cancellationToken);

ChatCompletion\DelegatingChatClientTests.cs (1)

82var enumerator = resultAsyncEnumerable.GetAsyncEnumerator();

SpeechToText\DelegatingSpeechToTextClientTests.cs (1)

83var enumerator = resultAsyncEnumerable.GetAsyncEnumerator();

SpeechToText\SpeechToTextClientExtensionsTests.cs (2)

43var ex1 = await Assert.ThrowsAsync<ArgumentNullException>(() => SpeechToTextClientExtensions.GetStreamingTextAsync(client!, content).GetAsyncEnumerator().MoveNextAsync().AsTask()); 48var ex2 = await Assert.ThrowsAsync<ArgumentNullException>(() => SpeechToTextClientExtensions.GetStreamingTextAsync(testClient, nullContent!).GetAsyncEnumerator().MoveNextAsync().AsTask());

AzureAIInferenceChatClientTests.cs (2)

43await Assert.ThrowsAsync<InvalidOperationException>(() => chatClient.GetStreamingResponseAsync("hello").GetAsyncEnumerator().MoveNextAsync().AsTask()); 46await Assert.ThrowsAsync<InvalidOperationException>(() => chatClient.GetStreamingResponseAsync("hello", new ChatOptions { ModelId = null }).GetAsyncEnumerator().MoveNextAsync().AsTask());

OpenAISpeechToTextClientTests.cs (1)

128.GetAsyncEnumerator()

ChatCompletion\ConfigureOptionsChatClientTests.cs (1)

80await using var e = client.GetStreamingResponseAsync(Array.Empty<ChatMessage>(), providedOptions, cts.Token).GetAsyncEnumerator();

ChatCompletion\DistributedCachingChatClientTest.cs (1)

835var actualEnumerator = actual.GetAsyncEnumerator();

SpeechToText\ConfigureOptionsSpeechToTextClientTests.cs (1)

83await using var e = client.GetStreamingTextAsync(audioSpeechStream2, providedOptions, cts.Token).GetAsyncEnumerator();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)

622Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException();

System\Linq\AggregateAsync.cs (2)

37await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 78await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\AggregateBy.cs (4)

57await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 128await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 195await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 267await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\AnyAsync.cs (1)

31await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\Chunk.cs (1)

42await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\CountAsync.cs (2)

32await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 133await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\CountBy.cs (2)

38await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 89await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\DefaultIfEmpty.cs (1)

45await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\Distinct.cs (1)

33await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\DistinctBy.cs (2)

45await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 95await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\ElementAtAsync.cs (2)

114await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 143await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\Except.cs (1)

39await using IAsyncEnumerator<TSource> firstEnumerator = first.GetAsyncEnumerator(cancellationToken);

System\Linq\ExceptBy.cs (2)

47await using IAsyncEnumerator<TSource> firstEnumerator = first.GetAsyncEnumerator(cancellationToken); 107await using IAsyncEnumerator<TSource> firstEnumerator = first.GetAsyncEnumerator(cancellationToken);

System\Linq\FirstAsync.cs (2)

32await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 154await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\GroupJoin.cs (2)

63await using IAsyncEnumerator<TOuter> e = outer.GetAsyncEnumerator(cancellationToken); 128await using IAsyncEnumerator<TOuter> e = outer.GetAsyncEnumerator(cancellationToken);

System\Linq\Intersect.cs (1)

40await using (IAsyncEnumerator<TSource> e = second.GetAsyncEnumerator(cancellationToken))

System\Linq\IntersectBy.cs (2)

53await using (IAsyncEnumerator<TKey> e = second.GetAsyncEnumerator(cancellationToken)) 118await using (IAsyncEnumerator<TKey> e = second.GetAsyncEnumerator(cancellationToken))

System\Linq\Join.cs (2)

59await using IAsyncEnumerator<TOuter> e = outer.GetAsyncEnumerator(cancellationToken); 133await using IAsyncEnumerator<TOuter> e = outer.GetAsyncEnumerator(cancellationToken);

System\Linq\LastAsync.cs (6)

31await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 76await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 130await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 190await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 260await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 310await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\LeftJoin.cs (2)

56await using IAsyncEnumerator<TOuter> e = outer.GetAsyncEnumerator(cancellationToken); 128await using IAsyncEnumerator<TOuter> e = outer.GetAsyncEnumerator(cancellationToken);

System\Linq\MaxAsync.cs (3)

64await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 133await using IAsyncEnumerator<float> e = source.GetAsyncEnumerator(cancellationToken); 174await using IAsyncEnumerator<double> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\MaxByAsync.cs (2)

42await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 152await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\MinAsync.cs (3)

61await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 130await using IAsyncEnumerator<float> e = source.GetAsyncEnumerator(cancellationToken); 175await using IAsyncEnumerator<double> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\MinByAsync.cs (2)

42await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 152await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\RightJoin.cs (2)

57await using IAsyncEnumerator<TInner> e = inner.GetAsyncEnumerator(cancellationToken); 129await using IAsyncEnumerator<TInner> e = inner.GetAsyncEnumerator(cancellationToken);

System\Linq\SequenceEqualAsync.cs (2)

39await using IAsyncEnumerator<TSource> e1 = first.GetAsyncEnumerator(cancellationToken); 40await using IAsyncEnumerator<TSource> e2 = second.GetAsyncEnumerator(cancellationToken);

System\Linq\SingleAsync.cs (6)

34await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 80await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 133await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 197await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 285await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 335await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\Skip.cs (1)

34await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\SkipWhile.cs (4)

43await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 92await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 145await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 199await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\Take.cs (3)

100await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 141await using (IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken)) 190await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\ToLookupAsync.cs (2)

93await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken); 200await using IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);

System\Linq\Zip.cs (9)

src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\ConfiguredCancelableAsyncEnumerable.cs (2)

35/// <summary>Sets the <see cref="CancellationToken"/> to be passed to <see cref="IAsyncEnumerable{T}.GetAsyncEnumerator(CancellationToken)"/> when iterating.</summary> 47new Enumerator(_enumerable.GetAsyncEnumerator(_cancellationToken), _continueOnCapturedContext);

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskAsyncEnumerableExtensions.cs (1)

31/// <summary>Sets the <see cref="CancellationToken"/> to be passed to <see cref="IAsyncEnumerable{T}.GetAsyncEnumerator(CancellationToken)"/> when iterating.</summary>

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskAsyncEnumerableExtensions.ToBlockingEnumerable.cs (1)

32IAsyncEnumerator<T> enumerator = source.GetAsyncEnumerator(cancellationToken);

System\Text\Json\Serialization\Converters\Collection\IAsyncEnumerableOfTConverter.cs (1)

54enumerator = value.GetAsyncEnumerator(state.CancellationToken);

System\Threading\Tasks\Parallel.ForEachAsync.cs (1)

718Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException(SR.Parallel_ForEach_NullEnumerator);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)

622Enumerator = source.GetAsyncEnumerator(Cancellation.Token) ?? throw new InvalidOperationException();

Sdk\AssertHelper.cs (1)

295 var enumerator = data.GetAsyncEnumerator();