ReadAllAsync

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

60await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 84await 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 (4)

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)

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

Dcp\DcpExecutor.cs (1)

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

Aspire.Hosting.Tests (4)

Dcp\DcpExecutorTests.cs (2)

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

Utils\Grpc\TestServerStreamWriter.cs (1)

30return _channel.Reader.ReadAllAsync();

Utils\TestConsoleLogsService.cs (1)

28await foreach (var result in 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 (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())

Stress.ApiService (2)

ProducerConsumer.cs (1)

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

Program.cs (1)

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