ReadAllAsync

22 references to ReadAllAsync

Aspire.Components.Common.Tests (1)

ActivityNotifier.cs (1)

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

Aspire.Dashboard.Components.Tests (2)

Shared\TestDashboardClient.cs (2)

52await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 71await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))

Aspire.Dashboard.Tests (1)

ResourceOutgoingPeerResolverTests.cs (1)

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

Aspire.Hosting (2)

ApplicationModel\ResourceLoggerService.cs (1)

126await foreach (var entry in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

ApplicationModel\ResourceNotificationService.cs (1)

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

Aspire.Hosting.Tests (1)

Dcp\ApplicationExecutorTests.cs (1)

558await foreach (var item in logStreamPipesChannel.Reader.ReadAllAsync())

Microsoft.AspNetCore.ConcurrencyLimiter.Tests (1)

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

35return _counters[counterName].Reader.ReadAllAsync(cancellationToken);

Microsoft.AspNetCore.Hosting.Tests (1)

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

35return _counters[counterName].Reader.ReadAllAsync(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 (3)

NativeAotTests.cs (3)

253await foreach (var item in source.ReadAllAsync()) 326await foreach (JsonElement item in source.ReadAllAsync()) 347await foreach (var item in source.ReadAllAsync())

Microsoft.CodeAnalysis.Workspaces (3)

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

72return channel.Reader.ReadAllAsync(cancellationToken);

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

94await args.consumeItems(items.ReadAllAsync(cancellationToken), args.args, cancellationToken).ConfigureAwait(false); 198consumeItems: static (reader, args, cancellationToken) => args.consumeItems(reader.ReadAllAsync(cancellationToken), args.args, cancellationToken),

Stress.ApiService (2)

ProducerConsumer.cs (1)

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

Program.cs (1)

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