ReadAllAsync

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

ResourceOutgoingPeerResolverTests.cs (1)

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

Telemetry\DashboardTelemetryServiceTests.cs (1)

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

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)

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

Dcp\DcpExecutor.cs (1)

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

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