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);
438 references to Reader
aspire (3)
Diagnostics\FileLoggerProvider.cs (1)
137await 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)
588await 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 _));
ClientSample (4)
UploadSample.cs (4)
45var invokeTask = connection.InvokeAsync<string>("UploadWord", channel.Reader); 65var result = await connection.InvokeAsync<string>("ScoreTracker", channel_one.Reader, channel_two.Reader); 95var outputs = await connection.StreamAsChannelAsync<string>("StreamEcho", channel.Reader);
GenerateDocumentationAndConfigFiles (3)
src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
InMemory.FunctionalTests (6)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (4)
91internal ChannelReader<KeyValuePair<Http3SettingType, long>> ServerReceivedSettingsReader => _serverReceivedSettings.Reader; 110var reader = MultiplexedConnectionContext.ToClientAcceptQueue.Reader; 1076while (await ToServerAcceptQueue.Reader.WaitToReadAsync(cancellationToken)) 1078while (ToServerAcceptQueue.Reader.TryRead(out var connection))
TestTransport\InMemoryTransportFactory.cs (2)
26if (await _acceptQueue.Reader.WaitToReadAsync(cancellationToken)) 28while (_acceptQueue.Reader.TryRead(out var item))
Metrics (3)
src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Metrics.Legacy (3)
src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.AspNetCore.Hosting.Tests (1)
src\Shared\EventSource.Testing\TestCounterListener.cs (1)
41var values = _counters[counterName].Reader.ReadAllAsync(cancellationToken).GetAsyncEnumerator(cancellationToken);
Microsoft.AspNetCore.Http.Connections.Tests (2)
TestWebSocketConnectionFeature.cs (2)
43var clientSocket = new WebSocketChannel(serverToClient.Reader, clientToServer.Writer, _sync); 44var serverSocket = new WebSocketChannel(clientToServer.Reader, serverToClient.Writer, _sync);
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.Server.Kestrel.Microbenchmarks (4)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (4)
91internal ChannelReader<KeyValuePair<Http3SettingType, long>> ServerReceivedSettingsReader => _serverReceivedSettings.Reader; 110var reader = MultiplexedConnectionContext.ToClientAcceptQueue.Reader; 1076while (await ToServerAcceptQueue.Reader.WaitToReadAsync(cancellationToken)) 1078while (ToServerAcceptQueue.Reader.TryRead(out var connection))
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (2)
Internal\NamedPipeConnectionListener.cs (2)
149while (await _acceptedQueue.Reader.WaitToReadAsync(cancellationToken)) 151if (_acceptedQueue.Reader.TryRead(out var connection))
Microsoft.AspNetCore.SignalR.Client.Core (6)
HubConnection.cs (1)
1614connectionState.InvocationMessageReceiveTask = StartProcessingInvocationMessages(invocationMessageChannel.Reader);
HubConnectionExtensions.StreamAsChannelAsync.cs (1)
282return outputChannel.Reader;
Internal\InvocationRequest.cs (1)
88public ChannelReader<object?> Result => _channel.Reader;
src\SignalR\common\Shared\MessageBuffer.cs (3)
142while (await _waitForAck.Reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false)) 144if (_waitForAck.Reader.TryRead(out var count) && count < _bufferLimit) 153_waitForAck.Reader.TryRead(out _);
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (14)
HubConnectionTests.cs (3)
800var channel = await connection.StreamAsChannelAsync<string>("StreamEcho", channelWriter.Reader).DefaultTimeout(); 2957while (await _taskQueue.Reader.WaitToReadAsync()) 2960while (_taskQueue.Reader.TryRead(out var tuple))
HubConnectionTests.Tracing.cs (8)
83clientActivity1 = await clientChannel.Reader.ReadAsync().DefaultTimeout(); 105clientActivity2 = await clientChannel.Reader.ReadAsync().DefaultTimeout(); 138var serverActivities = await serverChannel.Reader.ReadAtLeastAsync(minimumCount: 4).DefaultTimeout(); 310var serverActivities = await serverChannel.Reader.ReadAtLeastAsync(minimumCount: 3).DefaultTimeout(); 439var serverActivities = await serverChannel.Reader.ReadAtLeastAsync(minimumCount: 3).DefaultTimeout(); 536var serverActivities = await serverChannel.Reader.ReadAtLeastAsync(minimumCount: 3).DefaultTimeout(); 631var serverActivities = await serverChannel.Reader.ReadAtLeastAsync(minimumCount: 3).DefaultTimeout(); 730var serverActivities = await serverChannel.Reader.ReadAtLeastAsync(minimumCount: 3).DefaultTimeout();
Hubs.cs (3)
240return channel.Reader; 271return output.Reader; 295return output.Reader;
Microsoft.AspNetCore.SignalR.Client.Tests (18)
HubConnectionTests.cs (8)
439var invokeTask = hubConnection.InvokeAsync<int>("SomeMethod", channel.Reader); 479var sendTask = hubConnection.SendAsync("SomeMethod", channel.Reader); 510var invokeTask = hubConnection.InvokeAsync<SampleObject>("UploadMethod", channel.Reader); 555var invokeTask = hubConnection.InvokeAsync<object>("UploadMethod", channel.Reader, cts.Token); 587var invokeTask = hubConnection.InvokeAsync<object>("UploadMethod", channel.Reader, cts.Token); 612var invokeTask = hubConnection.InvokeAsync<object>("UploadMethod", channel.Reader); 646var invokeTask = hubConnection.InvokeAsync<long>("UploadMethod", channel.Reader); 679var invokeTask = hubConnection.InvokeAsync<int>("SumInts", channel.Reader);
HubServerProxyGeneratorTests.cs (10)
176var asyncEnumerable = channelForEnumerable.Reader.ReadAllAsync(); 186.Returns(Task.FromResult(channel.Reader)); 193.Returns(Task.FromResult(channel.Reader)); 217var channelReader = channel.Reader; 219var asyncEnumerable = channelForEnumerable.Reader.ReadAllAsync(); 259var retChannelReader = retChannel.Reader; 261var argEnumerable = argChannelForEnumerable.Reader.ReadAllAsync(); 263var retEnumerable = retChannelForEnumerable.Reader.ReadAllAsync(); 297_ = await myHub.StreamBidirectionalViaChannel(argChannel.Reader); 298_ = await myHub.StreamBidirectionalViaChannelWithToken(argChannel.Reader, token);
Microsoft.AspNetCore.SignalR.Core (7)
Internal\ChannelBasedSemaphore.cs (2)
26return _channel.Reader.TryRead(out _); 32return _channel.Reader.ReadAsync(cancellationToken);
src\SignalR\common\Shared\MessageBuffer.cs (3)
142while (await _waitForAck.Reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false)) 144if (_waitForAck.Reader.TryRead(out var count) && count < _bufferLimit) 153_waitForAck.Reader.TryRead(out _);
StreamTracker.cs (2)
124return _channel.Reader.ReadAllAsync(); 128return _channel.Reader;
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
DefaultHubDispatcherBenchmark.cs (1)
171return channel.Reader;
Microsoft.AspNetCore.SignalR.Tests (39)
HubConnectionHandlerTests.Activity.cs (20)
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(); 381var activities = await serverChannel.Reader.ReadAtLeastAsync(minimumCount: 2); 431var activities = await serverChannel.Reader.ReadAtLeastAsync(minimumCount: 2); 482var activities = await serverChannel.Reader.ReadAtLeastAsync(minimumCount: 2);
HubConnectionHandlerTests.cs (1)
4752provider.AddSingleton(channel.Reader);
HubConnectionHandlerTestUtils\Hubs.cs (14)
296return channel.Reader; 715return channel.Reader; 773return Channel.CreateUnbounded<string>().Reader; 780return channel.Reader; 787return channel.Reader; 794return channel.Reader; 829return output.Reader; 1030return Channel.CreateUnbounded<string>().Reader; 1045return channel.Reader; 1060return channel.Reader; 1075return channel.Reader; 1090return channel.Reader; 1105return channel.Reader; 1146return channel.Reader;
NativeAotTests.cs (4)
80var echoResponseReader = await connection.StreamAsChannelAsync<string>(nameof(AsyncMethodHub.StreamEcho), channel.Reader); 118stringResult = await connection.InvokeAsync<string>(nameof(AsyncMethodHub.ChannelShortParameter), channelShorts.Reader); 261return output.Reader; 295return output.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\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.CodeAnalysis.AnalyzerUtilities (3)
src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.CodeAnalysis.BannedApiAnalyzers (3)
src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.CodeAnalysis.CodeStyle (3)
src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (3)
src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.CodeAnalysis.PublicApiAnalyzers (3)
src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.CodeAnalysis.ResxSourceGenerator (3)
src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
Microsoft.CodeAnalysis.Threading.Package (2)
ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.Workspaces (3)
src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.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\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
SignalR.Client.FunctionalTestApp (3)
TestHub.cs (3)
67return channel.Reader; 80return channel.Reader; 102return channel.Reader;
SignalRSamples (4)
Hubs\Streaming.cs (1)
45return channel.Reader;
Hubs\UploadHub.cs (1)
81return output.Reader;
ObservableExtensions.cs (2)
35channel.Reader.Completion.ContinueWith(task => 41return channel.Reader;
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.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)
1213while (await _writeChannel.Reader.WaitToReadAsync().ConfigureAwait(false)) 1215while (_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}";
Test.Utilities (3)
src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);
TestDiscoveryWorker (2)
Program.cs (2)
124while (await _channel.Reader.WaitToReadAsync(CancellationToken.None).ConfigureAwait(false)) 126while (_channel.Reader.TryRead(out var item))
Text.Analyzers (3)
src\Dependencies\Threading\ProducerConsumer.cs (2)
279return channel.Reader.ReadAllAsync(cancellationToken); 351return await consumeItems(channel.Reader, args, cancellationToken).ConfigureAwait(false);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
63return channel.Reader.ReadAllAsync(cancellationToken);