ReadAllAsync

Backchannel\AuxiliaryBackchannelMonitor.cs (1)

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

Backchannel\ResourceSnapshotWatcher.cs (1)

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

Commands\PsCommand.cs (1)

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

Diagnostics\FileLoggerProvider.cs (1)

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

Projects\ProjectLocator.cs (1)

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

NativeSmokeHarness.cs (1)

432await foreach (var snapshot in _snapshots.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Backchannel\ResourceSnapshotWatcherTests.cs (1)

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

Backchannel\TrayWatchStreamTests.cs (7)

113var monitor = new TestAuxiliaryBackchannelMonitor { WatchConnectionsHandler = token => snapshots.Reader.ReadAllAsync(token) }; 621var monitor = new TestAuxiliaryBackchannelMonitor { WatchConnectionsHandler = token => snapshots.Reader.ReadAllAsync(token) }; 744var monitor = new TestAuxiliaryBackchannelMonitor { WatchConnectionsHandler = token => snapshots.Reader.ReadAllAsync(token) }; 803await foreach (var resource in resourceUpdates.Reader.ReadAllAsync(token)) 825connection.WatchResourceSnapshotsHandler = (_, token) => resourceUpdates.Reader.ReadAllAsync(token); 870var monitor = new TestAuxiliaryBackchannelMonitor { WatchConnectionsHandler = token => snapshots.Reader.ReadAllAsync(token) }; 1004await foreach (var connections in snapshots.Reader.ReadAllAsync(token))

TestServices\TestAuxiliaryBackchannelMonitor.cs (1)

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

760await foreach (var update in _incomingInteractionChannel.Reader.ReadAllAsync(cts.Token).ConfigureAwait(false)) 980await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken: enumeratorCancellationToken).ConfigureAwait(false)) 1033await foreach (var batch in channel.Reader.ReadAllAsync(combinedTokens.Token).ConfigureAwait(false))

ServiceClient\SqliteResourceRepository.cs (2)

154await foreach (var lines in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 484await foreach (var changes in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

tests\Shared\TestDashboardClient.cs (5)

134await foreach (var update in provider().Reader.ReadAllAsync(cancellationToken)) 171await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 186await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 219await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 244await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))

tests\Shared\TestDashboardClient.cs (5)

134await foreach (var update in provider().Reader.ReadAllAsync(cancellationToken)) 171await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 186await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 219await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 244await 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()));

tests\Shared\TestDashboardClient.cs (5)

134await foreach (var update in provider().Reader.ReadAllAsync(cancellationToken)) 171await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 186await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 219await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 244await 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)

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

Backchannel\AppHostRpcTarget.cs (1)

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

Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)

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

Dcp\DcpResourceWatcher.cs (1)

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

Dcp\KubernetesService.cs (1)

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

InteractionService.cs (1)

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

AzureProvisioningController.cs (1)

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

DevTunnelMonitor.cs (1)

731await foreach (var operation in _operations.Reader.ReadAllAsync().ConfigureAwait(false))

FoundryExtensions.cs (1)

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

Api\PipelineApi.cs (1)

85_activities.Reader.ReadAllAsync(cancellationToken);

NativeDiagnosticPump.cs (1)

24await foreach (var operation in _subscription.Reader.ReadAllAsync().ConfigureAwait(false))

src\Shared\ChildProcess.cs (1)

703await foreach (var line in lines.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Dcp\DcpExecutorTests.cs (2)

514await foreach (var item in channel.Reader.ReadAllAsync()) 3889await foreach (var item in logStreamPipesChannel.Reader.ReadAllAsync())

ResourceCommandServiceTests.cs (2)

162await foreach (var resourceName in commandResourcesChannel.Reader.ReadAllAsync().DefaultTimeout()) 204await foreach (var resourceName in commandResourcesChannel.Reader.ReadAllAsync().DefaultTimeout())

Utils\Grpc\TestServerStreamWriter.cs (1)

32return _channel.Reader.ReadAllAsync();

Utils\TestConsoleLogsService.cs (1)

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

Helpers\TestAppHostClient.cs (1)

35await foreach (var snapshot in _snapshots.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

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

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

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

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

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