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)

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

Aspire.Hosting (3)

ApplicationModel\ResourceLoggerService.cs (2)

191await foreach (var item in channel.Reader.ReadAllAsync().ConfigureAwait(false)) 237await 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 (2)

Dcp\ApplicationExecutorTests.cs (1)

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

Utils\Grpc\TestServerStreamWriter.cs (1)

30return _channel.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.Extensions.AI (1)

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

158return updates.Reader.ReadAllAsync(cancellationToken);

Stress.ApiService (2)

ProducerConsumer.cs (1)

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

Program.cs (1)

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