ReadAllAsync

73 references to ReadAllAsync

aspire (1)

Diagnostics\FileLoggerProvider.cs (1)

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

Aspire.Components.Common.TestUtilities (1)

ActivityNotifier.cs (1)

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

Aspire.Dashboard (5)

Otlp\Storage\TelemetryRepository.Watchers.cs (2)

102await foreach (var span in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 186await foreach (var log in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

ServiceClient\DashboardClient.cs (3)

470await foreach (var update in _incomingInteractionChannel.Reader.ReadAllAsync(cts.Token).ConfigureAwait(false)) 671await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken: enumeratorCancellationToken).ConfigureAwait(false)) 717await foreach (var batch in channel.Reader.ReadAllAsync(combinedTokens.Token).ConfigureAwait(false))

Aspire.Dashboard.Components.Tests (4)

tests\Shared\TestDashboardClient.cs (4)

71await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 86await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 105await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 125await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))

Aspire.Dashboard.Tests (6)

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)

71await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 86await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 105await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 125await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))

Aspire.Hosting (7)

ApplicationModel\ResourceLoggerService.cs (2)

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

ApplicationModel\ResourceNotificationService.cs (1)

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

Backchannel\AppHostRpcTarget.cs (1)

48await foreach (var entry in channel.Reader.ReadAllAsync(linkedToken).ConfigureAwait(false))

Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)

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

Dcp\DcpExecutor.cs (1)

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

InteractionService.cs (1)

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

Aspire.Hosting.Tests (6)

Dcp\DcpExecutorTests.cs (2)

99await foreach (var item in channel.Reader.ReadAllAsync()) 848await foreach (var item in logStreamPipesChannel.Reader.ReadAllAsync())

ResourceCommandServiceTests.cs (2)

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

dotnet (1)

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

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

GenerateDocumentationAndConfigFiles (6)

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

Microsoft.AspNetCore.SignalR.Core (1)

StreamTracker.cs (1)

124return _channel.Reader.ReadAllAsync();

Microsoft.CodeAnalysis.Analyzers (5)

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

Microsoft.CodeAnalysis.AnalyzerUtilities (5)

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

Microsoft.CodeAnalysis.CodeStyle (5)

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

Microsoft.CodeAnalysis.ResxSourceGenerator (5)

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

Microsoft.CodeAnalysis.Workspaces (6)

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

Microsoft.DotNet.HotReload.Watch (1)

Aspire\AspireServiceFactory.cs (1)

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

Roslyn.Diagnostics.Analyzers (5)

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

Stress.ApiService (2)

ProducerConsumer.cs (1)

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

Program.cs (1)

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

System.IO.FileSystem.Watcher (1)

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

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