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)
264 references to ReadAsync
aspire (1)
Interaction\ExtensionInteractionService.cs (1)
695var taskFunction = await _extensionTaskChannel.Reader.ReadAsync().ConfigureAwait(false);
Aspire.Cli.Tests (20)
Backchannel\TrayWatchStreamTests.cs (14)
465var initial = await messages.Reader.ReadAsync().AsTask().DefaultTimeout(); 470var retried = await messages.Reader.ReadAsync().AsTask().DefaultTimeout(); 595Assert.Equal((second + 1) * TrayWatchStream.MaximumConcurrentDashboardLookups, await batches.Reader.ReadAsync().AsTask().DefaultTimeout()); 650var initial = await messages.Reader.ReadAsync().AsTask().DefaultTimeout(); 668var snapshot = await messages.Reader.ReadAsync().AsTask().DefaultTimeout(); 792var message = await messages.Reader.ReadAsync().AsTask().DefaultTimeout(); 838Assert.Equal("healthy", Assert.Single((await messages.Reader.ReadAsync().AsTask().DefaultTimeout()).AppHosts!).Health); 841var message = await messages.Reader.ReadAsync().AsTask().DefaultTimeout(); 881var first = Assert.Single((await messages.Reader.ReadAsync().AsTask().DefaultTimeout()).AppHosts!); 886Assert.Empty((await messages.Reader.ReadAsync().AsTask().DefaultTimeout()).AppHosts!); 891var second = Assert.Single((await messages.Reader.ReadAsync().AsTask().DefaultTimeout()).AppHosts!); 957Assert.Equal("healthy", Assert.Single((await messages.Reader.ReadAsync().DefaultTimeout()).AppHosts!).Health); 961Assert.Empty((await messages.Reader.ReadAsync().DefaultTimeout()).AppHosts!); 964var host = Assert.Single((await messages.Reader.ReadAsync().DefaultTimeout()).AppHosts!);
Commands\AgentMcpCommandTests.cs (4)
1074var notification = await notificationChannel.Reader.ReadAsync(ctx.Cts.Token).AsTask().DefaultTimeout(); 1257await notificationChannel.Reader.ReadAsync(timeoutCts.Token); 1324var notification = await notificationChannel.Reader.ReadAsync(ctx.Cts.Token).AsTask().DefaultTimeout(); 1376await 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 (23)
Controls\TerminalWindowButtonTests.cs (4)
255Assert.Equal(["first", "inactive"], await checkedKeys.Reader.ReadAsync().AsTask().DefaultTimeout()); 258Assert.Equal(["new"], await checkedKeys.Reader.ReadAsync().AsTask().DefaultTimeout()); 322Assert.Equal(["first"], await failedKeys.Reader.ReadAsync().AsTask().DefaultTimeout()); 325Assert.Equal(["new"], await failedKeys.Reader.ReadAsync().AsTask().DefaultTimeout());
Interactions\InteractionsProviderTests.cs (6)
129Assert.Same(request, await liveRequestsChannel.Reader.ReadAsync().AsTask().DefaultTimeout()); 190await sendInteractionUpdatesChannel.Reader.ReadAsync(); 299var update = await sendInteractionUpdatesChannel.Reader.ReadAsync(); 362var update = await sendInteractionUpdatesChannel.Reader.ReadAsync(); 471var update = await sendInteractionUpdatesChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 664var update = await sendInteractionUpdatesChannel.Reader.ReadAsync();
Interactions\InteractionsProviderTests.Terminal.cs (5)
50var (content, parameters) = await shown.Reader.ReadAsync().AsTask().DefaultTimeout(); 68var request = await requests.Reader.ReadAsync().AsTask().DefaultTimeout(); 102Assert.IsType<InteractionsProgressDialogViewModel>((await shown.Reader.ReadAsync().AsTask().DefaultTimeout()).Content); 130var (content, _) = await shown.Reader.ReadAsync().AsTask().DefaultTimeout(); 146var (inputContent, inputParameters) = await shown.Reader.ReadAsync().AsTask().DefaultTimeout();
Layout\TerminalDockInitializationTests.cs (3)
46Assert.Same(update, await processed.Reader.ReadAsync().AsTask().DefaultTimeout()); 58await processed.Reader.ReadAsync().AsTask().DefaultTimeout(); 72await processed.Reader.ReadAsync().AsTask().DefaultTimeout();
Layout\TerminalDockWindowTrackingTests.cs (2)
199await started.Reader.ReadAsync().AsTask().DefaultTimeout(); 211await started.Reader.ReadAsync().AsTask().DefaultTimeout();
Pages\ConsoleLogsTests.cs (2)
138var subscribedResourceName1 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout(); 165var subscribedResourceName2 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout();
tests\Shared\TestDashboardClient.cs (1)
113return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask();
Aspire.Dashboard.Playwright.Tests (6)
Integration\Playwright\Infrastructure\TestTerminalConnectionResolver.cs (2)
31_connections.Reader.ReadAsync(cancellationToken).AsTask(); 74if (await Workload.InputEvents.ReadAsync(cancellationToken) is Hex1bKeyEvent key)
Integration\Playwright\TerminalDockTests.cs (3)
359Assert.Equal(closed, await closes.Reader.ReadAsync().AsTask().DefaultTimeout()); 383Assert.Equal("replacement", await closes.Reader.ReadAsync().AsTask().DefaultTimeout()); 401Assert.Equal("first", await closes.Reader.ReadAsync().AsTask().DefaultTimeout());
tests\Shared\TestDashboardClient.cs (1)
113return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask();
Aspire.Dashboard.Tests (21)
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();
Model\DashboardClientTests.cs (5)
628Assert.Equal(1, await subscriptionsStarted.Reader.ReadAsync().AsTask().DefaultTimeout()); 635Assert.Equal(2, await subscriptionsStarted.Reader.ReadAsync().AsTask().DefaultTimeout()); 644Assert.Equal(3, await subscriptionsStarted.Reader.ReadAsync().AsTask().DefaultTimeout()); 1147Assert.True(await disposed.Reader.ReadAsync().AsTask().DefaultTimeout()); 1149Assert.True(await disposed.Reader.ReadAsync().AsTask().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();
Terminal\TerminalWebSocketTests.cs (4)
186var inputEvent = await host.Workload.InputEvents.ReadAsync(timeout.Token); 471input = await host.Workload.InputEvents.ReadAsync(timeout.Token); 522var inputEvent = await host.Workload.InputEvents.ReadAsync(timeout.Token); 566input = await host.Workload.InputEvents.ReadAsync(timeout.Token);
tests\Shared\TestDashboardClient.cs (1)
113return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask();
Aspire.Hosting (1)
Backchannel\AppHostRpcTarget.cs (1)
92publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(linkedToken).ConfigureAwait(false);
Aspire.Hosting.Azure.Tests (32)
AzureDeployerTests.cs (11)
132var interaction = await interactionService.Interactions.Reader.ReadAsync(); 241var tenantInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 257var subscriptionInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 275var resourceGroupInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 293var locationInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 1001var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1072var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1264var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1309var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 2098var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 2167var interaction = await testInteractionService.Interactions.Reader.ReadAsync();
AzureEnvironmentResourceExtensionsTests.cs (10)
720var interaction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().WaitAsync(s_testSynchronizationTimeout); 748var notification = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().WaitAsync(s_testSynchronizationTimeout); 759var inputs = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().WaitAsync(s_testSynchronizationTimeout); 770var repeatedNotification = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().WaitAsync(s_testSynchronizationTimeout); 3110var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 3284var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 3415var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 3541var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 3604var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 4452var interaction = await testInteractionService.Interactions.Reader.ReadAsync();
ProvisioningContextProviderTests.cs (11)
37var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 99var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 159var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 542var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 638var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 700var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 843var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 890var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 934var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 993var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 1037var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync();
Aspire.Hosting.DevTunnels.Tests (5)
DevTunnelMonitorTests.cs (2)
133Assert.Equal(TimeSpan.FromSeconds(1), await time.ScheduledDelays.Reader.ReadAsync().AsTask().DefaultTimeout()); 676var notification = await test.Interaction.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();
DevTunnelResourceBuilderExtensionsTests.cs (3)
580var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 632var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 680var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();
Aspire.Hosting.Native.Core.Tests (12)
NativeDiagnosticChannelTests.cs (7)
20Assert.Equal(first, await fast.Reader.ReadAsync(TestContext.Current.CancellationToken)); 22Assert.Equal(second, await fast.Reader.ReadAsync(TestContext.Current.CancellationToken)); 23Assert.Equal(first, await slow.Reader.ReadAsync(TestContext.Current.CancellationToken)); 26Assert.Equal(first, await fast.Reader.ReadAsync(TestContext.Current.CancellationToken)); 38Assert.Equal(operation, await first.Reader.ReadAsync(TestContext.Current.CancellationToken)); 40Assert.Equal(operation, await second.Reader.ReadAsync(TestContext.Current.CancellationToken)); 52var awaited = subscription.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask();
SocketConnectionListenerTests.cs (4)
49await connected.Reader.ReadAsync(timeout.Token); 51await connected.Reader.ReadAsync(timeout.Token); 110await connected.Reader.ReadAsync(timeout.Token); 112await connected.Reader.ReadAsync(timeout.Token);
TestServices\RecordingBackchannelRpc.cs (1)
17_connections.Reader.ReadAsync(cancellationToken).AsTask();
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 (124)
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)
69var logContext = await logChannel.Reader.ReadAsync().DefaultTimeout(); 141var logContext = await logChannel.Reader.ReadAsync().DefaultTimeout();
Dashboard\DashboardServiceTests.cs (2)
1792var log = await logs.Reader.ReadAsync().AsTask().DefaultTimeout(); 1828var log = await logs.Reader.ReadAsync().AsTask().DefaultTimeout();
Dcp\DcpExecutorTests.cs (10)
259await endpointEventsProcessed.Reader.ReadAsync().AsTask().DefaultTimeout(); 268await endpointEventsProcessed.Reader.ReadAsync().AsTask().DefaultTimeout(); 2576var followStdErrPipe = await followStdErrPipeChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3064var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 3106var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 4514var allocatedPort = await allocatedPortChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4515var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4563var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4645var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4687var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().DefaultTimeout();
Dcp\DcpHostNotificationTests.cs (7)
112var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 156var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 299var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 354var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 421var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 933var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 1081var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout();
Dcp\KubernetesServiceTests.cs (3)
198startedResourceName = await requestsStarted.Reader.ReadAsync(cts.Token).DefaultTimeout(); 204watchedResourceName = await requestsStarted.Reader.ReadAsync(cts.Token).DefaultTimeout(); 213var nextResourceName = await requestsStarted.Reader.ReadAsync(cts.Token).DefaultTimeout();
Dcp\TestKubernetesService.cs (1)
333var (evtType, res) = await chan.Reader.ReadAsync(cancellationToken);
DistributedApplicationTests.cs (2)
1233await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout(); 1243await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout();
DotnetProgramPublishingTests.cs (1)
390var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().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 (49)
174var messageBarInteraction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 178var inputsInteraction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 281var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 289var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 374var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 395var newNotification = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 425var prompt = await interactions.Interactions.Reader.ReadAsync().DefaultTimeout(); 434prompt = await interactions.Interactions.Reader.ReadAsync().DefaultTimeout(); 453prompt = await interactions.Interactions.Reader.ReadAsync().DefaultTimeout(); 461prompt = await interactions.Interactions.Reader.ReadAsync().DefaultTimeout(); 558var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 562var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 608var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 612var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 651var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 655var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 686var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 690var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 725var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 729var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 1291var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1337var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1492var notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1494var prompt = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1516var notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1518var prompt = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1717var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1720var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1758var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1761var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1802var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1805var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1888var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1893var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1983notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2035interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2037interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2046interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2048interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2151var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2201var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2239var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2286var notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2326var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2330var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2377var setInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2387var deleteInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2399var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2403var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();
Publishing\ContainerRuntimeReadinessTests.cs (4)
57var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 87var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 131var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 164var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout();
Publishing\PipelineActivityReporterTests.cs (6)
571var activity = await activityReader.ReadAsync().DefaultTimeout(); 598var activity = await activityReader.ReadAsync().DefaultTimeout(); 627var activity = await activityReader.ReadAsync().DefaultTimeout(); 656var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 696var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 726var 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)
1299var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1473var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1866var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1919var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout();
VersionChecking\VersionCheckServiceTests.cs (7)
37var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 131var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 174var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 287var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 317var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 346var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 374var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout();
Aspire.Tray.Tests (4)
Helpers\TestAppHostClient.cs (4)
93=> _starting.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().WaitAsync(TimeSpan.FromSeconds(10)); 96=> _finishedStarts.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().WaitAsync(TimeSpan.FromSeconds(10)); 106=> _started.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().WaitAsync(TimeSpan.FromSeconds(10)); 109=> _finished.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().WaitAsync(TimeSpan.FromSeconds(10));
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)
578return 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>