ReadAllAsync

ActivityNotifier.cs (1)

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

ServiceClient\DashboardClient.cs (2)

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

Shared\TestDashboardClient.cs (3)

69await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 93await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 113await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))

ResourceOutgoingPeerResolverTests.cs (1)

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

Telemetry\DashboardTelemetryServiceTests.cs (1)

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

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)

549await 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)

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

Dcp\DcpExecutorTests.cs (2)

97await foreach (var item in channel.Reader.ReadAllAsync()) 740await 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)

61return 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)

61return channel.Reader.ReadAllAsync(cancellationToken);

ProducerConsumer.cs (1)

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

Program.cs (1)

220await 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)

61return channel.Reader.ReadAllAsync(cancellationToken);