ReadAllAsync

Backchannel\AuxiliaryBackchannelMonitor.cs (1)

96await foreach (var _ in connectionChanges.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Backchannel\ResourceSnapshotWatcher.cs (1)

220await foreach (var _ in updateSignal.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Commands\PsCommand.cs (1)

219await foreach (var update in updates.Reader.ReadAllAsync(followCancellationToken).ConfigureAwait(false))

Diagnostics\FileLoggerProvider.cs (1)

115await foreach (var message in _channel.Reader.ReadAllAsync())

Projects\ProjectLocator.cs (1)

204await foreach (var candidate in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Backchannel\ResourceSnapshotWatcherTests.cs (1)

562await foreach (var snapshot in source.ReadAllAsync(cancellationToken))

TestServices\TestAuxiliaryBackchannelMonitor.cs (1)

42await foreach (var _ in _connectionChanges.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

ActivityNotifier.cs (1)

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

Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (2)

259await foreach (var span in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 315await foreach (var log in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

ServiceClient\DashboardClient.cs (3)

716await foreach (var update in _incomingInteractionChannel.Reader.ReadAllAsync(cts.Token).ConfigureAwait(false)) 923await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken: enumeratorCancellationToken).ConfigureAwait(false)) 976await foreach (var batch in channel.Reader.ReadAllAsync(combinedTokens.Token).ConfigureAwait(false))

ServiceClient\SqliteResourceRepository.cs (2)

148await foreach (var lines in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 477await foreach (var changes in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

tests\Shared\TestDashboardClient.cs (4)

102await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 117await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 142await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 162await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))

ResourceOutgoingPeerResolverTests.cs (4)

341await foreach (var item in sourceChannel.Reader.ReadAllAsync(cancellationToken)) 366subscribeResult.SetResult(new ResourceViewModelSubscription([], sourceChannel.Reader.ReadAllAsync())); 386sourceChannel.Reader.ReadAllAsync())); 412subscribeResult.SetResult(new ResourceViewModelSubscription([], sourceChannel.Reader.ReadAllAsync()));

Telemetry\DashboardTelemetryServiceTests.cs (1)

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

tests\Shared\TestDashboardClient.cs (4)

102await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 117await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 142await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 162await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))

ApplicationModel\ResourceLoggerService.cs (2)

251await foreach (var entry in channel.Reader.ReadAllAsync(linkedCts.Token).ConfigureAwait(false)) 338await foreach (var item in channel.Reader.ReadAllAsync().ConfigureAwait(false))

ApplicationModel\ResourceNotificationService.cs (1)

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

Backchannel\AppHostRpcTarget.cs (1)

61await foreach (var entry in AsyncEnumerableUtils.ReadUntilCancelledAsync(channel.Reader.ReadAllAsync(linkedToken), linkedToken).ConfigureAwait(false))

Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)

1687await foreach (var logLine in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Dcp\DcpResourceWatcher.cs (1)

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

InteractionService.cs (1)

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

AzureProvisioningController.cs (1)

1490await foreach (var operation in _operationChannel.Reader.ReadAllAsync(stoppingToken).ConfigureAwait(false))

FoundryExtensions.cs (1)

473await foreach (var progress in progressChannel.Reader.ReadAllAsync(ct).ConfigureAwait(false))

Dcp\DcpExecutorTests.cs (2)

162await foreach (var item in channel.Reader.ReadAllAsync()) 3424await foreach (var item in logStreamPipesChannel.Reader.ReadAllAsync())

ResourceCommandServiceTests.cs (2)

161await foreach (var resourceName in commandResourcesChannel.Reader.ReadAllAsync().DefaultTimeout()) 203await 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))

parent\dotnet\Commands\Test\MTP\TestApplicationActionQueue.cs (1)

105await foreach (var nonParallelizedGroup in _channel.Reader.ReadAllAsync(_cancellationToken))

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

18=> reader.ReadAllAsync(cancellationToken);

src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

57return channel.Reader.ReadAllAsync(cancellationToken);

StreamTracker.cs (1)

149return _channel.Reader.ReadAllAsync();

src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

57return channel.Reader.ReadAllAsync(cancellationToken);

src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

57return channel.Reader.ReadAllAsync(cancellationToken);

src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

57return channel.Reader.ReadAllAsync(cancellationToken);

src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

57return channel.Reader.ReadAllAsync(cancellationToken);

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

18=> reader.ReadAllAsync(cancellationToken);

src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

57return channel.Reader.ReadAllAsync(cancellationToken);

Aspire\AspireServiceFactory.cs (1)

183await foreach (var line in outputChannel.Reader.ReadAllAsync(cancellationToken))

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

162return updates.Reader.ReadAllAsync(cancellationToken);

src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

57return channel.Reader.ReadAllAsync(cancellationToken);

ProducerConsumer.cs (1)

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

Program.cs (1)

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

System\IO\FileSystemWatcher.Linux.cs (1)

1109await foreach (WatcherEvent @event in _eventQueue.Reader.ReadAllAsync().ConfigureAwait(false))