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)) 651await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken: enumeratorCancellationToken).ConfigureAwait(false)) 697await 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)

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

Backchannel\AppHostRpcTarget.cs (1)

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

Dcp\DcpExecutor.cs (1)

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

InteractionService.cs (1)

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

Dcp\DcpExecutorTests.cs (2)

98await foreach (var item in channel.Reader.ReadAllAsync()) 747await 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);

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

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