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)
170 references to ReadAsync
aspire (1)
Interaction\ExtensionInteractionService.cs (1)
54var taskFunction = await _extensionTaskChannel.Reader.ReadAsync().ConfigureAwait(false);
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)
277var context = await testTelemetrySender.ContextChannel.Reader.ReadAsync().DefaultTimeout(); 290var 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)
81publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(linkedToken).ConfigureAwait(false);
Aspire.Hosting.Azure.Tests (26)
AzureDeployerTests.cs (10)
49var tenantInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 65var subscriptionInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 83var resourceGroupInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 101var locationInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 580var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 651var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 844var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 889var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1500var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1568var 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 (76)
Cli\CliOrphanDetectorTests.cs (8)
133Assert.Equal(1, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 137Assert.Equal(2, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 141Assert.Equal(3, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 209Assert.Equal(1, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 212Assert.Equal(2, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 215Assert.Equal(3, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 218Assert.Equal(4, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 221Assert.Equal(5, await processRunningChannel.Reader.ReadAsync().DefaultTimeout());
Dashboard\DashboardLifecycleHookTests.cs (1)
67var logContext = await logChannel.Reader.ReadAsync().DefaultTimeout();
Dcp\DcpHostNotificationTests.cs (6)
90var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 143await interactionService.Interactions.Reader.ReadAsync(cts.Token); 198await interactionService.Interactions.Reader.ReadAsync(cts.Token); 249var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 300var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 367var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token);
Dcp\TestKubernetesService.cs (1)
149var (evtType, res) = await chan.Reader.ReadAsync(cancellationToken);
DistributedApplicationTests.cs (2)
1084await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout(); 1094await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout();
Health\ResourceHealthCheckServiceTests.cs (5)
170var e1 = await channel.Reader.ReadAsync().DefaultTimeout(); 198var e2 = await channel.Reader.ReadAsync().DefaultTimeout(); 318var firstCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout(); 321var secondCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout(); 324var thirdCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout();
InteractionServiceTests.cs (9)
136Assert.Equal(interaction1.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 141Assert.Equal(interaction2.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 148var completedInteraction1 = await updates.Reader.ReadAsync().DefaultTimeout(); 156var completedInteraction2 = await updates.Reader.ReadAsync().DefaultTimeout(); 845var interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 854interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 900var interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 913interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 920interaction = await updates.Reader.ReadAsync().DefaultTimeout();
Orchestrator\ParameterProcessorTests.cs (37)
201var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 209var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 287var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 294var nextMessageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 385var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 389var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 435var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 439var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 478var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 482var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 513var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 517var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 552var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 556var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 912var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 956var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 989var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1025var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1039var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1074var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1084var firstInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1107var secondInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1273var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1276var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1314var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1317var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1358var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1361var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1399var firstInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1416var secondInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1452var firstInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1469var deleteConfirmation = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1509var inputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1545var firstInputInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1559var deleteConfirmation = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1568var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1575var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();
Publishing\PipelineActivityReporterTests.cs (4)
522var activity = await activityReader.ReadAsync().DefaultTimeout(); 549var activity = await activityReader.ReadAsync().DefaultTimeout(); 578var activity = await activityReader.ReadAsync().DefaultTimeout(); 613var activity = await activityReader.ReadAsync().DefaultTimeout();
VersionChecking\VersionCheckServiceTests.cs (3)
37var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 131var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 174var 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)
62await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 128await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout();
Http3\WebTransport\WebTransportTestUtilities.cs (1)
59await 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)
555/// <summary>Represents a blocked reader from <see cref="ChannelReader{T}.ReadAsync"/>.</summary>