5 overrides of ReadAsync
System.Threading.Channels (5)
System\Threading\Channels\BoundedChannel.cs (1)
147public override ValueTask<T> ReadAsync(CancellationToken cancellationToken)
System\Threading\Channels\RendezvousChannel.cs (1)
130public override ValueTask<T> ReadAsync(CancellationToken cancellationToken)
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)
70public override ValueTask<T> ReadAsync(CancellationToken cancellationToken)
System\Threading\Channels\UnboundedChannel.cs (1)
68public override ValueTask<T> ReadAsync(CancellationToken cancellationToken)
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
75public override ValueTask<T> ReadAsync(CancellationToken cancellationToken)
165 references to ReadAsync
aspire (1)
Interaction\ExtensionInteractionService.cs (1)
585var taskFunction = await _extensionTaskChannel.Reader.ReadAsync().ConfigureAwait(false);
Aspire.Cli.Tests (4)
Commands\AgentMcpCommandTests.cs (2)
383var notification = await notificationChannel.Reader.ReadAsync(ctx.Cts.Token).AsTask().DefaultTimeout(); 457await notificationChannel.Reader.ReadAsync(timeoutCts.Token);
Commands\LogsCommandTests.cs (2)
1465var initialLog = await logLines.Reader.ReadAsync().AsTask().DefaultTimeout(); 1472var followLog = await logLines.Reader.ReadAsync().AsTask().DefaultTimeout();
Aspire.Dashboard (1)
Api\TelemetryApiService.cs (1)
543await signal.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);
Aspire.Dashboard.Components.Tests (7)
Interactions\InteractionsProviderTests.cs (4)
128Assert.Same(request, await liveRequestsChannel.Reader.ReadAsync().AsTask().DefaultTimeout()); 283var update = await sendInteractionUpdatesChannel.Reader.ReadAsync(); 347var update = await sendInteractionUpdatesChannel.Reader.ReadAsync(); 616var update = await sendInteractionUpdatesChannel.Reader.ReadAsync();
Pages\ConsoleLogsTests.cs (2)
139var subscribedResourceName1 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout(); 165var subscribedResourceName2 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout();
tests\Shared\TestDashboardClient.cs (1)
80return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask();
Aspire.Dashboard.Tests (12)
ChannelExtensionsTests.cs (4)
130var read1 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 135var read2 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 174var read1 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 179var read2Task = resultChannel.Reader.ReadAsync().DefaultTimeout();
Integration\DashboardClientAuthTests.cs (2)
45var call = await server.Calls.ResourceInformationCallsChannel.Reader.ReadAsync().DefaultTimeout(); 62var call = await server.Calls.ResourceInformationCallsChannel.Reader.ReadAsync().DefaultTimeout();
ResourceOutgoingPeerResolverTests.cs (3)
304var readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 313readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 323readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout();
TelemetryRepositoryTests\LogTests.cs (2)
1002var read1 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 1023var read2 = await resultChannel.Reader.ReadAsync().DefaultTimeout();
tests\Shared\TestDashboardClient.cs (1)
80return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask();
Aspire.Hosting (1)
Backchannel\AppHostRpcTarget.cs (1)
90publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(linkedToken).ConfigureAwait(false);
Aspire.Hosting.Azure.Tests (28)
AzureDeployerTests.cs (10)
56var tenantInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 72var subscriptionInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 90var resourceGroupInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 108var locationInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 754var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 825var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1017var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1062var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1848var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1916var interaction = await testInteractionService.Interactions.Reader.ReadAsync();
AzureEnvironmentResourceExtensionsTests.cs (10)
424var interaction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().WaitAsync(s_testSynchronizationTimeout); 452var notification = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().WaitAsync(s_testSynchronizationTimeout); 463var inputs = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().WaitAsync(s_testSynchronizationTimeout); 474var repeatedNotification = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().WaitAsync(s_testSynchronizationTimeout); 2792var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 2966var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 3097var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 3223var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 3286var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 4134var interaction = await testInteractionService.Interactions.Reader.ReadAsync();
ProvisioningContextProviderTests.cs (8)
344var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 439var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 500var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 641var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 687var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 730var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 788var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 831var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync();
Aspire.Hosting.DevTunnels.Tests (3)
DevTunnelResourceBuilderExtensionsTests.cs (3)
476var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 528var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 576var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();
Aspire.Hosting.RemoteHost.Tests (2)
AtsExportsTests.cs (2)
93var data = await interactionService.Interactions.Reader.ReadAsync(); 135var data = await interactionService.Interactions.Reader.ReadAsync();
Aspire.Hosting.Tests (94)
AtsInteractionExportsTests.cs (2)
29var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 56var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout();
Cli\CliOrphanDetectorTests.cs (8)
162Assert.Equal(1, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 166Assert.Equal(2, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 170Assert.Equal(3, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 237Assert.Equal(1, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 240Assert.Equal(2, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 243Assert.Equal(3, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 246Assert.Equal(4, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 249Assert.Equal(5, await processRunningChannel.Reader.ReadAsync().DefaultTimeout());
Dashboard\DashboardEventHandlersTests.cs (2)
67var logContext = await logChannel.Reader.ReadAsync().DefaultTimeout(); 139var logContext = await logChannel.Reader.ReadAsync().DefaultTimeout();
Dcp\DcpExecutorTests.cs (6)
2128var followStdErrPipe = await followStdErrPipeChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3795var allocatedPort = await allocatedPortChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3796var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3844var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3926var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3968var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().DefaultTimeout();
Dcp\DcpHostNotificationTests.cs (13)
111var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 155var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 212await interactionService.Interactions.Reader.ReadAsync(cts.Token); 271await interactionService.Interactions.Reader.ReadAsync(cts.Token); 326var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 381var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 452var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 789await interactionService.Interactions.Reader.ReadAsync(cts.Token); 839await interactionService.Interactions.Reader.ReadAsync(cts.Token); 895var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 950await interactionService.Interactions.Reader.ReadAsync(cts.Token); 1008await interactionService.Interactions.Reader.ReadAsync(cts.Token); 1069var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token);
Dcp\TestKubernetesService.cs (1)
300var (evtType, res) = await chan.Reader.ReadAsync(cancellationToken);
DistributedApplicationTests.cs (2)
1229await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout(); 1239await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout();
Health\ResourceHealthCheckServiceTests.cs (5)
171var e1 = await channel.Reader.ReadAsync().DefaultTimeout(); 199var e2 = await channel.Reader.ReadAsync().DefaultTimeout(); 319var firstCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout(); 322var secondCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout(); 325var thirdCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout();
InteractionServiceTests.cs (9)
138Assert.Equal(interaction1.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 143Assert.Equal(interaction2.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 150var completedInteraction1 = await updates.Reader.ReadAsync().DefaultTimeout(); 158var completedInteraction2 = await updates.Reader.ReadAsync().DefaultTimeout(); 929var interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 938interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 984var interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 997interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 1004interaction = await updates.Reader.ReadAsync().DefaultTimeout();
Orchestrator\ParameterProcessorTests.cs (27)
204var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 212var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 297var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 397var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 401var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 447var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 451var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 490var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 494var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 525var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 529var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 564var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 568var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 1130var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1176var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1415var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1418var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1456var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1459var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1500var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1503var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1586var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1591var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1615var setInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1625var deleteInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1637var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1641var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();
Publishing\PipelineActivityReporterTests.cs (6)
573var activity = await activityReader.ReadAsync().DefaultTimeout(); 600var activity = await activityReader.ReadAsync().DefaultTimeout(); 629var activity = await activityReader.ReadAsync().DefaultTimeout(); 658var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 698var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 728var activity = await activityReader.ReadAsync().DefaultTimeout();
RequiredCommandAnnotationTests.cs (2)
403var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 459var interaction = await testInteractionService.Interactions.Reader.ReadAsync();
ResourceCommandServiceTests.cs (4)
1298var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1370var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1753var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1806var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout();
VersionChecking\VersionCheckServiceTests.cs (7)
39var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 133var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 176var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 289var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 319var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 348var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 376var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout();
dotnet-watch (1)
UI\SpectreBuildParametersSelectionPrompt.cs (1)
134=> await _channel.Reader.ReadAsync(cancellationToken);
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\WebTransport\WebTransportSession.cs (1)
175return await _pendingStreams.Reader.ReadAsync(cancellationToken);
Microsoft.AspNetCore.SignalR.Core (1)
Internal\ChannelBasedSemaphore.cs (1)
32return _channel.Reader.ReadAsync(cancellationToken);
Microsoft.Build.Tasks.Core (2)
AssemblyDependency\Node\RarNodeBuildEngine.cs (2)
120int eventCount = await _eventCountChannel.Reader.ReadAsync(cancellationToken).ConfigureAwait(false); 130BuildEventArgs buildEventArgs = await _eventChannel.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);
Microsoft.DotNet.HotReload.Utils.Generator (1)
Util\FSWGen.cs (1)
62var readOne = _channel!.Reader.ReadAsync(cancellationToken).AsTask();
Microsoft.Extensions.ServiceDiscovery.Tests (1)
ServiceEndpointResolverTests.cs (1)
275var next = await channel.Reader.ReadAsync(CancellationToken.None);
Microsoft.ML.Data (1)
Transforms\RowShufflingTransformer.cs (1)
637ValueTask<int> readTask = _toConsumeChannel.Reader.ReadAsync();
Microsoft.ML.Sweeper (1)
AsyncSweeper.cs (1)
282return await _paramChannel.Reader.ReadAsync(_cts.Token);
System.Net.Quic (2)
System\Net\Quic\QuicConnection.cs (1)
575return await _acceptQueue.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);
System\Net\Quic\QuicListener.cs (1)
185object item = await _acceptQueue.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);
System.Threading.Channels (1)
System\Threading\Channels\AsyncOperation.cs (1)
592/// <summary>Represents a blocked reader from <see cref="ChannelReader{T}.ReadAsync"/>.</summary>