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)
121 references to ReadAsync
aspire (1)
Interaction\ExtensionInteractionService.cs (1)
53var taskFunction = await _extensionTaskChannel.Reader.ReadAsync().ConfigureAwait(false);
Aspire.Dashboard.Components.Tests (5)
Interactions\InteractionsProviderTests.cs (2)
230var update = await sendInteractionUpdatesChannel.Reader.ReadAsync(); 293var update = await sendInteractionUpdatesChannel.Reader.ReadAsync();
Pages\ConsoleLogsTests.cs (2)
145var subscribedResourceName1 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout(); 171var subscribedResourceName2 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout();
tests\Shared\TestDashboardClient.cs (1)
57return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask();
Aspire.Dashboard.Tests (15)
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();
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)
57return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask();
Aspire.Hosting (1)
Backchannel\AppHostRpcTarget.cs (1)
57var publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Azure.Tests (13)
AzureDeployerTests.cs (7)
72var tenantInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 88var subscriptionInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 106var locationInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 459var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 530var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 698var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 743var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync();
ProvisioningContextProviderTests.cs (6)
268var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 275var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 362var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 367var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 424var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 431var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync();
Aspire.Hosting.Tests (42)
Dashboard\DashboardLifecycleHookTests.cs (1)
67var logContext = await logChannel.Reader.ReadAsync().DefaultTimeout();
Dcp\DcpHostNotificationTests.cs (6)
83var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 136await interactionService.Interactions.Reader.ReadAsync(cts.Token); 191await interactionService.Interactions.Reader.ReadAsync(cts.Token); 242var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 293var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 360var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token);
Dcp\TestKubernetesService.cs (1)
149var (evtType, res) = await chan.Reader.ReadAsync(cancellationToken);
DistributedApplicationTests.cs (2)
778await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout(); 788await 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 (10)
194var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 202var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 280var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 287var nextMessageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 378var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 382var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 425var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 429var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 465var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 469var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync();
Publishing\PipelineActivityReporterTests.cs (4)
462var activity = await activityReader.ReadAsync().DefaultTimeout(); 489var activity = await activityReader.ReadAsync().DefaultTimeout(); 518var activity = await activityReader.ReadAsync().DefaultTimeout(); 553var activity = await activityReader.ReadAsync().DefaultTimeout();
ResourceCommandServiceTests.cs (1)
153Assert.Equal(resourceName, await commandResourcesChannel.Reader.ReadAsync().DefaultTimeout());
VersionChecking\VersionCheckServiceTests.cs (3)
34var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 128var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 171var 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>