ReadAllAsync

49 references to ReadAllAsync

Aspire.Components.Common.TestUtilities (1)

ActivityNotifier.cs (1)

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

Aspire.Dashboard (2)

ServiceClient\DashboardClient.cs (2)

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

Aspire.Dashboard.Components.Tests (3)

Shared\TestDashboardClient.cs (3)

67await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 91await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 111await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))

Aspire.Dashboard.Tests (2)

ResourceOutgoingPeerResolverTests.cs (1)

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

Telemetry\DashboardTelemetryServiceTests.cs (1)

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

Aspire.Hosting (6)

ApplicationModel\InteractionService.cs (1)

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

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)

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

Backchannel\AppHostRpcTarget.cs (1)

39var logEntries = channel.Reader.ReadAllAsync(cancellationToken);

Dcp\DcpExecutor.cs (1)

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

Aspire.Hosting.Tests (5)

Dcp\DcpExecutorTests.cs (2)

94await foreach (var item in channel.Reader.ReadAllAsync()) 737await foreach (var item in logStreamPipesChannel.Reader.ReadAllAsync())

ResourceCommandServiceTests.cs (1)

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

GenerateDocumentationAndConfigFiles (5)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

72return channel.Reader.ReadAllAsync(cancellationToken);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (4)

94await args.consumeItems(items.ReadAllAsync(cancellationToken), args.args, cancellationToken).ConfigureAwait(false); 198consumeItems: static (reader, args, cancellationToken) => args.consumeItems(reader.ReadAllAsync(cancellationToken), args.args, cancellationToken), 285await foreach (var item in reader.ReadAllAsync(cancellationToken)) 296return channel.Reader.ReadAllAsync(cancellationToken);

Microsoft.AspNetCore.ConcurrencyLimiter.Tests (1)

src\Shared\EventSource.Testing\TestCounterListener.cs (1)

41var values = _counters[counterName].Reader.ReadAllAsync(cancellationToken).GetAsyncEnumerator(cancellationToken);

Microsoft.AspNetCore.Hosting.Tests (1)

src\Shared\EventSource.Testing\TestCounterListener.cs (1)

41var values = _counters[counterName].Reader.ReadAllAsync(cancellationToken).GetAsyncEnumerator(cancellationToken);

Microsoft.AspNetCore.SignalR.Client.Tests (4)

HubServerProxyGeneratorTests.cs (4)

176var asyncEnumerable = channelForEnumerable.Reader.ReadAllAsync(); 219var asyncEnumerable = channelForEnumerable.Reader.ReadAllAsync(); 261var argEnumerable = argChannelForEnumerable.Reader.ReadAllAsync(); 263var retEnumerable = retChannelForEnumerable.Reader.ReadAllAsync();

Microsoft.AspNetCore.SignalR.Core (1)

StreamTracker.cs (1)

124return _channel.Reader.ReadAllAsync();

Microsoft.AspNetCore.SignalR.Tests (5)

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

Microsoft.CodeAnalysis.Workspaces (5)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

72return channel.Reader.ReadAllAsync(cancellationToken);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (4)

Microsoft.Extensions.AI (1)

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

164return updates.Reader.ReadAllAsync(cancellationToken);

Stress.ApiService (2)

ProducerConsumer.cs (1)

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

Program.cs (1)

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

Test.Utilities (5)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

72return channel.Reader.ReadAllAsync(cancellationToken);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (4)