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)
181 references to ReadAsync
aspire (1)
Interaction\ExtensionInteractionService.cs (1)
55var taskFunction = await _extensionTaskChannel.Reader.ReadAsync().ConfigureAwait(false);
Aspire.Cli.Tests (2)
Commands\AgentMcpCommandTests.cs (2)
408var notification = await notificationChannel.Reader.ReadAsync(_cts.Token).AsTask().DefaultTimeout(); 487await notificationChannel.Reader.ReadAsync(timeoutCts.Token);
Aspire.Dashboard.Components.Tests (5)
Interactions\InteractionsProviderTests.cs (2)
232var update = await sendInteractionUpdatesChannel.Reader.ReadAsync(); 295var update = await sendInteractionUpdatesChannel.Reader.ReadAsync();
Pages\ConsoleLogsTests.cs (2)
137var subscribedResourceName1 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout(); 163var subscribedResourceName2 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout();
tests\Shared\TestDashboardClient.cs (1)
59return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask();
Aspire.Dashboard.Tests (17)
ChannelExtensionsTests.cs (4)
91var read1 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 96var read2 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 135var read1 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 140var read2Task = resultChannel.Reader.ReadAsync().DefaultTimeout();
Integration\DashboardClientAuthTests.cs (2)
44var call = await server.Calls.ResourceInformationCallsChannel.Reader.ReadAsync().DefaultTimeout(); 60var call = await server.Calls.ResourceInformationCallsChannel.Reader.ReadAsync().DefaultTimeout();
Integration\McpServiceTests.cs (2)
285var context = await testTelemetrySender.ContextChannel.Reader.ReadAsync().DefaultTimeout(); 298var context = await testTelemetrySender.ContextChannel.Reader.ReadAsync().DefaultTimeout();
Model\AIAssistant\AIContextProviderTests.cs (3)
93var newContext = await changeChannel.Reader.ReadAsync().DefaultTimeout(); 97newContext = await changeChannel.Reader.ReadAsync().DefaultTimeout(); 103var newContextTask = changeChannel.Reader.ReadAsync();
ResourceOutgoingPeerResolverTests.cs (3)
151readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 159readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 167readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout();
TelemetryRepositoryTests\LogTests.cs (2)
748var read1 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 769var read2 = await resultChannel.Reader.ReadAsync().DefaultTimeout();
tests\Shared\TestDashboardClient.cs (1)
59return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask();
Aspire.Hosting (1)
Backchannel\AppHostRpcTarget.cs (1)
71publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(linkedToken).ConfigureAwait(false);
Aspire.Hosting.Azure.Tests (26)
AzureDeployerTests.cs (10)
50var tenantInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 66var subscriptionInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 84var resourceGroupInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 102var locationInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 577var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 648var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 840var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 885var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1604var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1672var interaction = await testInteractionService.Interactions.Reader.ReadAsync();
ProvisioningContextProviderTests.cs (16)
270var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 277var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 376var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 381var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 439var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 446var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 588var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 592var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 635var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 639var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 679var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 683var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 738var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 742var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 782var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 786var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync();
Aspire.Hosting.Tests (85)
Cli\CliOrphanDetectorTests.cs (8)
132Assert.Equal(1, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 136Assert.Equal(2, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 140Assert.Equal(3, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 207Assert.Equal(1, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 210Assert.Equal(2, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 213Assert.Equal(3, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 216Assert.Equal(4, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 219Assert.Equal(5, await processRunningChannel.Reader.ReadAsync().DefaultTimeout());
Dashboard\DashboardLifecycleHookTests.cs (1)
70var logContext = await logChannel.Reader.ReadAsync().DefaultTimeout();
Dcp\DcpHostNotificationTests.cs (13)
110var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 156var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 215await interactionService.Interactions.Reader.ReadAsync(cts.Token); 276await interactionService.Interactions.Reader.ReadAsync(cts.Token); 333var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 390var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 463var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 561await interactionService.Interactions.Reader.ReadAsync(cts.Token); 613await interactionService.Interactions.Reader.ReadAsync(cts.Token); 671var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 728await interactionService.Interactions.Reader.ReadAsync(cts.Token); 788await interactionService.Interactions.Reader.ReadAsync(cts.Token); 851var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token);
Dcp\TestKubernetesService.cs (1)
149var (evtType, res) = await chan.Reader.ReadAsync(cancellationToken);
DistributedApplicationTests.cs (2)
1085await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout(); 1095await 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)
137Assert.Equal(interaction1.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 142Assert.Equal(interaction2.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 149var completedInteraction1 = await updates.Reader.ReadAsync().DefaultTimeout(); 157var completedInteraction2 = await updates.Reader.ReadAsync().DefaultTimeout(); 846var interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 855interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 901var interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 914interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 921interaction = await updates.Reader.ReadAsync().DefaultTimeout();
Orchestrator\ParameterProcessorTests.cs (37)
202var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 210var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 288var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 295var nextMessageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 386var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 390var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 436var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 440var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 479var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 483var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 514var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 518var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 553var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 557var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 913var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 957var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 990var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1026var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1040var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1075var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1085var firstInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1108var secondInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1256var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1259var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1297var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1300var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1341var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1344var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1382var firstInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1399var secondInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1435var firstInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1452var deleteConfirmation = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1492var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1528var firstInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1542var deleteConfirmation = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1551var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1558var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();
Publishing\PipelineActivityReporterTests.cs (4)
523var activity = await activityReader.ReadAsync().DefaultTimeout(); 550var activity = await activityReader.ReadAsync().DefaultTimeout(); 579var activity = await activityReader.ReadAsync().DefaultTimeout(); 614var activity = await activityReader.ReadAsync().DefaultTimeout();
RequiredCommandAnnotationTests.cs (2)
371var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 427var interaction = await testInteractionService.Interactions.Reader.ReadAsync();
VersionChecking\VersionCheckServiceTests.cs (3)
38var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 132var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 175var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout();
InMemory.FunctionalTests (8)
Http3\Http3ConnectionTests.cs (1)
414var maxFieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout();
Http3\Http3StreamTests.cs (4)
2816var maxFieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 3246var fieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 3251fieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 3255fieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout();
Http3\WebTransport\WebTransportHandshakeTests.cs (2)
67await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 139await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout();
Http3\WebTransport\WebTransportTestUtilities.cs (1)
63await inMemory.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout();
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\WebTransport\WebTransportSession.cs (1)
175return await _pendingStreams.Reader.ReadAsync(cancellationToken);
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (8)
HubConnectionTests.cs (6)
803Assert.Equal("1", await channel.ReadAsync().AsTask().DefaultTimeout()); 805Assert.Equal("2", await channel.ReadAsync().AsTask().DefaultTimeout()); 850Assert.Equal("A", await channel.ReadAsync().AsTask().DefaultTimeout()); 851Assert.Equal("B", await channel.ReadAsync().AsTask().DefaultTimeout()); 852Assert.Equal("C", await channel.ReadAsync().AsTask().DefaultTimeout()); 853Assert.Equal("D", await channel.ReadAsync().AsTask().DefaultTimeout());
HubConnectionTests.Tracing.cs (2)
83clientActivity1 = await clientChannel.Reader.ReadAsync().DefaultTimeout(); 105clientActivity2 = await clientChannel.Reader.ReadAsync().DefaultTimeout();
Microsoft.AspNetCore.SignalR.Core (1)
Internal\ChannelBasedSemaphore.cs (1)
32return _channel.Reader.ReadAsync(cancellationToken);
Microsoft.AspNetCore.SignalR.Tests (20)
HubConnectionHandlerTests.Activity.cs (17)
54var connectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 63var invocation1Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 69var invocation2Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 75var invocation3Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 78var userCodeActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 87var disconnectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 129var connectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 145var invocationActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 159var disconnectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 200var connectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 205var invocation1Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 210var invocation2Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 218var disconnectedActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 259var connectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 271var invocationActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 285var disconnectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 330var activity = await serverChannel.Reader.ReadAsync().DefaultTimeout();
HubConnectionHandlerTestUtils\Hubs.cs (3)
917var result = _channel.ReadAsync(_cancellationToken); 1380total += await channelReader.ReadAsync(); 1409await channelReader.ReadAsync();
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)
560/// <summary>Represents a blocked reader from <see cref="ChannelReader{T}.ReadAsync"/>.</summary>