ReadAllAsync

ActivityNotifier.cs (1)

41await foreach (var activity in _activityChannel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

ServiceClient\DashboardClient.cs (3)

450await foreach (var update in _incomingInteractionChannel.Reader.ReadAllAsync(cts.Token).ConfigureAwait(false)) 639await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken: enumeratorCancellationToken).ConfigureAwait(false)) 685await foreach (var batch in channel.Reader.ReadAllAsync(combinedTokens.Token).ConfigureAwait(false))

tests\Shared\TestDashboardClient.cs (4)

69await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 84await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 103await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 123await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))

ResourceOutgoingPeerResolverTests.cs (1)

184await foreach (var item in sourceChannel.Reader.ReadAllAsync(cancellationToken))

Telemetry\DashboardTelemetryServiceTests.cs (1)

68await foreach (var item in sender.ContextChannel.Reader.ReadAllAsync())

tests\Shared\TestDashboardClient.cs (4)

69await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 84await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 103await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 123await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))

ApplicationModel\ResourceLoggerService.cs (2)

239await foreach (var entry in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 318await foreach (var item in channel.Reader.ReadAllAsync().ConfigureAwait(false))

ApplicationModel\ResourceNotificationService.cs (1)

556await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Backchannel\AppHostRpcTarget.cs (1)

39var logEntries = channel.Reader.ReadAllAsync(cancellationToken);

Dcp\DcpExecutor.cs (1)

275await foreach (var entry in _logInformationChannel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

InteractionService.cs (1)

450await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Dcp\DcpExecutorTests.cs (2)

96await foreach (var item in channel.Reader.ReadAllAsync()) 742await foreach (var item in logStreamPipesChannel.Reader.ReadAllAsync())

ResourceCommandServiceTests.cs (2)

105await foreach (var resourceName in commandResourcesChannel.Reader.ReadAllAsync().DefaultTimeout()) 142await foreach (var resourceName in commandResourcesChannel.Reader.ReadAllAsync().DefaultTimeout())

Utils\Grpc\TestServerStreamWriter.cs (1)

30return _channel.Reader.ReadAllAsync();

Utils\TestConsoleLogsService.cs (1)

28await foreach (var result in channel.Reader.ReadAllAsync(cancellationToken))

src\Dependencies\Threading\ChannelReaderExtensions.cs (1)

18=> reader.ReadAllAsync(cancellationToken);

src\Dependencies\Threading\ProducerConsumer.cs (4)

77await args.consumeItems(items.ReadAllAsync(cancellationToken), args.args, cancellationToken).ConfigureAwait(false); 181consumeItems: static (reader, args, cancellationToken) => args.consumeItems(reader.ReadAllAsync(cancellationToken), args.args, cancellationToken), 268await foreach (var item in reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 279return channel.Reader.ReadAllAsync(cancellationToken);

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

63return channel.Reader.ReadAllAsync(cancellationToken);

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);

HubServerProxyGeneratorTests.cs (4)

176var asyncEnumerable = channelForEnumerable.Reader.ReadAllAsync(); 219var asyncEnumerable = channelForEnumerable.Reader.ReadAllAsync(); 261var argEnumerable = argChannelForEnumerable.Reader.ReadAllAsync(); 263var retEnumerable = retChannelForEnumerable.Reader.ReadAllAsync();

StreamTracker.cs (1)

124return _channel.Reader.ReadAllAsync();

NativeAotTests.cs (5)

86await foreach (var item in echoResponseReader.ReadAllAsync()) 101await foreach (var item in returnChannelValueTypeReader.ReadAllAsync()) 253await foreach (var item in source.ReadAllAsync()) 326await foreach (JsonElement item in source.ReadAllAsync()) 347await foreach (var item in source.ReadAllAsync())

ChannelReaderExtensions.cs (1)

18=> reader.ReadAllAsync(cancellationToken);

ProducerConsumer.cs (4)

77await args.consumeItems(items.ReadAllAsync(cancellationToken), args.args, cancellationToken).ConfigureAwait(false); 181consumeItems: static (reader, args, cancellationToken) => args.consumeItems(reader.ReadAllAsync(cancellationToken), args.args, cancellationToken), 268await foreach (var item in reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 279return channel.Reader.ReadAllAsync(cancellationToken);

src\Dependencies\Threading\ChannelReaderExtensions.cs (1)

18=> reader.ReadAllAsync(cancellationToken);

src\Dependencies\Threading\ProducerConsumer.cs (4)

77await args.consumeItems(items.ReadAllAsync(cancellationToken), args.args, cancellationToken).ConfigureAwait(false); 181consumeItems: static (reader, args, cancellationToken) => args.consumeItems(reader.ReadAllAsync(cancellationToken), args.args, cancellationToken), 268await foreach (var item in reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 279return channel.Reader.ReadAllAsync(cancellationToken);

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

63return channel.Reader.ReadAllAsync(cancellationToken);

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

162return updates.Reader.ReadAllAsync(cancellationToken);

ProducerConsumer.cs (1)

30await foreach (var item in _channel.Reader.ReadAllAsync())

Program.cs (1)

273await foreach (var message in channel.Reader.ReadAllAsync(cancellationToken))

src\Dependencies\Threading\ChannelReaderExtensions.cs (1)

18=> reader.ReadAllAsync(cancellationToken);

src\Dependencies\Threading\ProducerConsumer.cs (4)

77await args.consumeItems(items.ReadAllAsync(cancellationToken), args.args, cancellationToken).ConfigureAwait(false); 181consumeItems: static (reader, args, cancellationToken) => args.consumeItems(reader.ReadAllAsync(cancellationToken), args.args, cancellationToken), 268await foreach (var item in reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 279return channel.Reader.ReadAllAsync(cancellationToken);

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

63return channel.Reader.ReadAllAsync(cancellationToken);