5 writes to Reader
System.Threading.Channels (5)
System\Threading\Channels\BoundedChannel.cs (1)
64Reader = new BoundedChannelReader(this);
System\Threading\Channels\RendezvousChannel.cs (1)
55Reader = new RendezvousChannelReader(this);
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)
47Reader = new UnboundedChannelReader(this);
System\Threading\Channels\UnboundedChannel.cs (1)
41Reader = new UnboundedChannelReader(this);
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
48Reader = new UnboundedPrioritizedChannelReader(this);
317 references to Reader
aspire (3)
Diagnostics\FileLoggerProvider.cs (1)
115await foreach (var message in _channel.Reader.ReadAllAsync())
Interaction\ExtensionInteractionService.cs (2)
51while (await _extensionTaskChannel.Reader.WaitToReadAsync().ConfigureAwait(false)) 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.Components.Common.TestUtilities (1)
ActivityNotifier.cs (1)
41await foreach (var activity in _activityChannel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Aspire.Confluent.Kafka (1)
MetricsChannel.cs (1)
23public ChannelReader<string> Reader => _channel.Reader;
Aspire.Dashboard (12)
Otlp\Storage\TelemetryRepository.Watchers.cs (4)
89while (channel.Reader.TryRead(out var pendingSpan)) 102await foreach (var span in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 175while (channel.Reader.TryRead(out var pendingLog)) 186await foreach (var log in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
ServiceClient\DashboardClient.cs (3)
470await foreach (var update in _incomingInteractionChannel.Reader.ReadAllAsync(cts.Token).ConfigureAwait(false)) 671await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken: enumeratorCancellationToken).ConfigureAwait(false)) 717await foreach (var batch in channel.Reader.ReadAllAsync(combinedTokens.Token).ConfigureAwait(false))
src\Shared\ChannelExtensions.cs (2)
36if (await channel.Reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false)) 48while (!cancellationToken.IsCancellationRequested && channel.Reader.TryRead(out var log))
Telemetry\DashboardTelemetrySender.cs (3)
51while (await _channel.Reader.WaitToReadAsync().ConfigureAwait(false)) 53while (_channel.Reader.TryRead(out var operation)) 107while (_channel.Reader.TryRead(out _))
Aspire.Dashboard.Components.Tests (10)
Interactions\InteractionsProviderTests.cs (2)
232var update = await sendInteractionUpdatesChannel.Reader.ReadAsync(); 295var update = await sendInteractionUpdatesChannel.Reader.ReadAsync();
Pages\ConsoleLogsTests.cs (3)
137var subscribedResourceName1 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout(); 163var subscribedResourceName2 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout(); 167Assert.False(await subscribedResourceNamesChannel.Reader.WaitToReadAsync().DefaultTimeout());
tests\Shared\TestDashboardClient.cs (5)
59return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask(); 71await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 86await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 105await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 125await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))
Aspire.Dashboard.Tests (41)
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 (4)
283while (await testTelemetrySender.ContextChannel.Reader.WaitToReadAsync().DefaultTimeout()) 285var context = await testTelemetrySender.ContextChannel.Reader.ReadAsync().DefaultTimeout(); 296while (await testTelemetrySender.ContextChannel.Reader.WaitToReadAsync().DefaultTimeout()) 298var context = await testTelemetrySender.ContextChannel.Reader.ReadAsync().DefaultTimeout();
Model\AIAssistant\AIContextProviderTests.cs (4)
93var newContext = await changeChannel.Reader.ReadAsync().DefaultTimeout(); 97newContext = await changeChannel.Reader.ReadAsync().DefaultTimeout(); 103var newContextTask = changeChannel.Reader.ReadAsync(); 115Assert.False(await changeChannel.Reader.WaitToReadAsync().DefaultTimeout());
ResourceOutgoingPeerResolverTests.cs (6)
142Assert.False(resultChannel.Reader.TryRead(out readValue)); 151readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 159readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 167readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 179Assert.False(await resultChannel.Reader.WaitToReadAsync().DefaultTimeout()); 184await foreach (var item in sourceChannel.Reader.ReadAllAsync(cancellationToken))
Telemetry\ComponentTelemetryContextTests.cs (9)
29Assert.True(telemetrySender.ContextChannel.Reader.TryRead(out var postPropertyOperation)); 33Assert.True(telemetrySender.ContextChannel.Reader.TryRead(out var initializeOperation)); 44Assert.True(telemetrySender.ContextChannel.Reader.TryRead(out parametersUpdateOperation)); 51Assert.False(telemetrySender.ContextChannel.Reader.TryRead(out parametersUpdateOperation)); 55Assert.True(telemetrySender.ContextChannel.Reader.TryRead(out parametersUpdateOperation)); 59Assert.True(telemetrySender.ContextChannel.Reader.TryRead(out var disposeOperation)); 77Assert.False(telemetrySender.ContextChannel.Reader.TryRead(out _)); 102Assert.False(telemetrySender.ContextChannel.Reader.TryRead(out _)); 106Assert.False(telemetrySender.ContextChannel.Reader.TryRead(out _));
Telemetry\DashboardTelemetryServiceTests.cs (1)
68await foreach (var item in sender.ContextChannel.Reader.ReadAllAsync())
Telemetry\TelemetryLoggerProviderTests.cs (4)
33Assert.False(telemetrySender.ContextChannel.Reader.TryPeek(out _)); 38Assert.False(telemetrySender.ContextChannel.Reader.TryPeek(out _)); 42Assert.False(telemetrySender.ContextChannel.Reader.TryPeek(out _)); 46Assert.True(telemetrySender.ContextChannel.Reader.TryPeek(out var context));
TelemetryRepositoryTests\LogTests.cs (2)
748var read1 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 769var read2 = await resultChannel.Reader.ReadAsync().DefaultTimeout();
tests\Shared\TestDashboardClient.cs (5)
59return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask(); 71await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 86await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 105await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 125await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))
Aspire.Hosting (11)
ApplicationModel\ResourceLoggerService.cs (2)
248await foreach (var entry in channel.Reader.ReadAllAsync(linkedCts.Token).ConfigureAwait(false)) 335await foreach (var item in channel.Reader.ReadAllAsync().ConfigureAwait(false))
ApplicationModel\ResourceNotificationService.cs (1)
607await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Backchannel\AppHostRpcTarget.cs (2)
48await foreach (var entry in channel.Reader.ReadAllAsync(linkedToken).ConfigureAwait(false)) 71publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(linkedToken).ConfigureAwait(false);
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
738await foreach (var logLine in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Dcp\DcpExecutor.cs (1)
401await foreach (var entry in _logInformationChannel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Devcontainers\DevcontainerSettingsWriter.cs (1)
69var reader = _portUpdates.Reader;
InteractionService.cs (1)
473await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
src\Shared\ChannelExtensions.cs (2)
36if (await channel.Reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false)) 48while (!cancellationToken.IsCancellationRequested && channel.Reader.TryRead(out var log))
Aspire.Hosting.Azure.Tests (30)
AzureDeployerTests.cs (14)
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(); 619Assert.Equal(0, testInteractionService.Interactions.Reader.Count); 648var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 815Assert.Equal(0, testInteractionService.Interactions.Reader.Count); 840var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 885var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1604var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1669if (testInteractionService.Interactions.Reader.Count > 0) 1672var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 1676Assert.Equal(0, testInteractionService.Interactions.Reader.Count);
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 (149)
Backchannel\BackchannelLoggerProviderTests.cs (6)
97Assert.True(channel1.Reader.TryRead(out var entry1a)); 99Assert.True(channel1.Reader.TryRead(out var entry1b)); 102Assert.True(channel2.Reader.TryRead(out var entry2a)); 104Assert.True(channel2.Reader.TryRead(out var entry2b)); 111await channel1.Reader.Completion; 112await channel2.Reader.Completion;
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\DcpExecutorTests.cs (2)
99await foreach (var item in channel.Reader.ReadAllAsync()) 848await foreach (var item in logStreamPipesChannel.Reader.ReadAllAsync())
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 (46)
41var activityReader = reporter.ActivityItemUpdated.Reader; 64reporter.ActivityItemUpdated.Reader.TryRead(out _); 80var activityReader = reporter.ActivityItemUpdated.Reader; 134reporter.ActivityItemUpdated.Reader.TryRead(out _); 145var activityReader = reporter.ActivityItemUpdated.Reader; 166reporter.ActivityItemUpdated.Reader.TryRead(out _); 167reporter.ActivityItemUpdated.Reader.TryRead(out _); 178var activityReader = reporter.ActivityItemUpdated.Reader; 238reporter.ActivityItemUpdated.Reader.TryRead(out _); 239reporter.ActivityItemUpdated.Reader.TryRead(out _); 251var activityReader = reporter.ActivityItemUpdated.Reader; 294var activityReader = reporter.ActivityItemUpdated.Reader; 315var activityReader = reporter.ActivityItemUpdated.Reader; 348var activityReader = reporter.ActivityItemUpdated.Reader; 518var activityReader = reporter.ActivityItemUpdated.Reader; 549var activityReader = reporter.ActivityItemUpdated.Reader; 578var activityReader = reporter.ActivityItemUpdated.Reader; 613var activityReader = reporter.ActivityItemUpdated.Reader; 660reporter.ActivityItemUpdated.Reader.TryRead(out _); 670var activityReader = reporter.ActivityItemUpdated.Reader; 704var activityReader = reporter.ActivityItemUpdated.Reader; 748reporter.ActivityItemUpdated.Reader.TryRead(out _); 749reporter.ActivityItemUpdated.Reader.TryRead(out _); 761var activityReader = reporter.ActivityItemUpdated.Reader; 783reporter.ActivityItemUpdated.Reader.TryRead(out _); 784reporter.ActivityItemUpdated.Reader.TryRead(out _); 796var activityReader = reporter.ActivityItemUpdated.Reader; 820var activityReader = reporter.ActivityItemUpdated.Reader; 841var activityReader = reporter.ActivityItemUpdated.Reader; 867var activityReader = reporter.ActivityItemUpdated.Reader; 894var activityReader = reporter.ActivityItemUpdated.Reader; 917var activityReader = reporter.ActivityItemUpdated.Reader; 931reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 942var activityReader = reporter.ActivityItemUpdated.Reader; 960reporter.ActivityItemUpdated.Reader.TryRead(out _); 967var activityReader = reporter.ActivityItemUpdated.Reader; 1011reporter.ActivityItemUpdated.Reader.TryRead(out _); 1012reporter.ActivityItemUpdated.Reader.TryRead(out _); 1022var activityReader = reporter.ActivityItemUpdated.Reader; 1034reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 1041var activityReader = reporter.ActivityItemUpdated.Reader; 1061var activityReader = reporter.ActivityItemUpdated.Reader; 1081var activityReader = reporter.ActivityItemUpdated.Reader; 1100var activityReader = reporter.ActivityItemUpdated.Reader; 1268while (reporter.ActivityItemUpdated.Reader.TryRead(out _)) { } 1273Assert.False(reporter.ActivityItemUpdated.Reader.TryRead(out _));
RequiredCommandAnnotationTests.cs (4)
371var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 402Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 427var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 435Assert.False(testInteractionService.Interactions.Reader.TryRead(out _));
ResourceCommandServiceTests.cs (2)
105await foreach (var resourceName in commandResourcesChannel.Reader.ReadAllAsync().DefaultTimeout()) 147await foreach (var resourceName in commandResourcesChannel.Reader.ReadAllAsync().DefaultTimeout())
Utils\Grpc\TestAsyncStreamReader.cs (2)
39if (await _channel.Reader.WaitToReadAsync(cancellationToken) && 40_channel.Reader.TryRead(out var message))
Utils\Grpc\TestServerStreamWriter.cs (3)
30return _channel.Reader.ReadAllAsync(); 35if (await _channel.Reader.WaitToReadAsync()) 37_channel.Reader.TryRead(out var message);
Utils\TestConsoleLogsService.cs (1)
28await foreach (var result in channel.Reader.ReadAllAsync(cancellationToken))
VersionChecking\VersionCheckServiceTests.cs (7)
38var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 102Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 132var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 175var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 183Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 218Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 247Assert.False(interactionService.Interactions.Reader.TryRead(out var _));
dotnet (1)
Commands\Test\MTP\TestApplicationActionQueue.cs (1)
53await foreach (var nonParallelizedGroup in _channel.Reader.ReadAllAsync())
dotnet-watch (2)
UI\SpectreBuildParametersSelectionPrompt.cs (2)
128=> _channel.Reader.TryPeek(out _); 134=> await _channel.Reader.ReadAsync(cancellationToken);
GenerateDocumentationAndConfigFiles (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.AspNetCore.Server.Kestrel.Core (3)
Internal\Http2\Http2FrameWriter.cs (2)
178while (await _channel.Reader.WaitToReadAsync()) 182while (_channel.Reader.TryRead(out var producer) && !producer.CompletedResponse)
Internal\WebTransport\WebTransportSession.cs (1)
175return await _pendingStreams.Reader.ReadAsync(cancellationToken);
Microsoft.AspNetCore.SignalR.Core (7)
Internal\ChannelBasedSemaphore.cs (2)
26return _channel.Reader.TryRead(out _); 32return _channel.Reader.ReadAsync(cancellationToken);
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (3)
146while (await _waitForAck.Reader.WaitToReadAsync(linkedToken).ConfigureAwait(false)) 148if (_waitForAck.Reader.TryRead(out var count) && count < _bufferLimit) 157_waitForAck.Reader.TryRead(out _);
StreamTracker.cs (2)
124return _channel.Reader.ReadAllAsync(); 128return _channel.Reader;
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.CodeAnalysis.Analyzers (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.CodeAnalysis.AnalyzerUtilities (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.CodeAnalysis.CodeStyle (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.CodeAnalysis.ResxSourceGenerator (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.CodeAnalysis.Workspaces (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.DotNet.HotReload.Utils.Generator (2)
Util\FSWGen.cs (2)
60var completion = _channel!.Reader.Completion.ContinueWith((t) => WhenAnyResult.Completion); 62var readOne = _channel!.Reader.ReadAsync(cancellationToken).AsTask();
Microsoft.DotNet.HotReload.Watch (1)
Aspire\AspireServiceFactory.cs (1)
183await foreach (var line in outputChannel.Reader.ReadAllAsync(cancellationToken))
Microsoft.Extensions.ServiceDiscovery.Tests (1)
ServiceEndpointResolverTests.cs (1)
275var next = await channel.Reader.ReadAsync(CancellationToken.None);
Microsoft.ML.Data (3)
Transforms\RowShufflingTransformer.cs (3)
571while (await _toProduceChannel.Reader.WaitToReadAsync().ConfigureAwait(false)) 574if (!_toProduceChannel.Reader.TryRead(out requested)) 637ValueTask<int> readTask = _toConsumeChannel.Reader.ReadAsync();
Microsoft.ML.Sweeper (1)
AsyncSweeper.cs (1)
282return await _paramChannel.Reader.ReadAsync(_cts.Token);
Roslyn.Diagnostics.Analyzers (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Stress.ApiService (2)
ProducerConsumer.cs (1)
30await foreach (var item in _channel.Reader.ReadAllAsync())
Program.cs (1)
273await foreach (var message in channel.Reader.ReadAllAsync(cancellationToken))
System.Diagnostics.Process (2)
System\Diagnostics\Process.Multiplexing.cs (2)
551while (await channel.Reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false)) 553while (channel.Reader.TryRead(out ProcessOutputLine line))
System.IO.FileSystem.Watcher (1)
System\IO\FileSystemWatcher.Linux.cs (1)
1100await foreach (WatcherEvent @event in _eventQueue.Reader.ReadAllAsync().ConfigureAwait(false))
System.Net.Http (2)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (2)
1214while (await _writeChannel.Reader.WaitToReadAsync().ConfigureAwait(false)) 1216while (_writeChannel.Reader.TryRead(out WriteQueueEntry? writeEntry))
System.Net.Quic (4)
System\Net\Quic\QuicConnection.cs (2)
575return await _acceptQueue.Reader.ReadAsync(cancellationToken).ConfigureAwait(false); 864while (_acceptQueue.Reader.TryRead(out QuicStream? stream))
System\Net\Quic\QuicListener.cs (2)
185object item = await _acceptQueue.Reader.ReadAsync(cancellationToken).ConfigureAwait(false); 433while (_acceptQueue.Reader.TryRead(out object? item))
System.Threading.Channels (2)
System\Threading\Channels\Channel_2.cs (1)
22public static implicit operator ChannelReader<TRead>(Channel<TWrite, TRead> channel) => channel.Reader;
System\Threading\Channels\RendezvousChannel.cs (1)
487$"{((RendezvousChannelReader)Reader).DebuggerDisplay}, {((RendezvousChannelWriter)Writer).DebuggerDisplay}";