ReadAllAsync

Backchannel\AuxiliaryBackchannelMonitor.cs (1)

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

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

260await foreach (var span in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 316await foreach (var log in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

ServiceClient\DashboardClient.cs (3)

712await foreach (var update in _incomingInteractionChannel.Reader.ReadAllAsync(cts.Token).ConfigureAwait(false)) 919await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken: enumeratorCancellationToken).ConfigureAwait(false)) 972await 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)

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

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

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

Dcp\DcpExecutorTests.cs (2)

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

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

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

src\sdk\src\Cli\dotnet\Commands\Test\MTP\TestApplicationActionQueue.cs (1)

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