Reader

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);

Backchannel\AuxiliaryBackchannelMonitor.cs (1)

109await foreach (var _ in connectionChanges.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Backchannel\ResourceSnapshotWatcher.cs (1)

220await foreach (var _ in updateSignal.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Commands\PsCommand.cs (1)

219await foreach (var update in updates.Reader.ReadAllAsync(followCancellationToken).ConfigureAwait(false))

Diagnostics\FileLoggerProvider.cs (1)

115await foreach (var message in _channel.Reader.ReadAllAsync())

Interaction\ExtensionInteractionService.cs (2)

581while (await _extensionTaskChannel.Reader.WaitToReadAsync(_cancellationToken).ConfigureAwait(false)) 585var taskFunction = await _extensionTaskChannel.Reader.ReadAsync().ConfigureAwait(false);

Projects\ProjectLocator.cs (1)

204await foreach (var candidate 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))

Backchannel\ResourceSnapshotWatcherTests.cs (1)

453ReadSnapshotsAndSignalFirstApplied(source.Reader, firstSnapshotApplied, cancellationToken)

Commands\AgentMcpCommandTests.cs (2)

383var notification = await notificationChannel.Reader.ReadAsync(ctx.Cts.Token).AsTask().DefaultTimeout(); 457await notificationChannel.Reader.ReadAsync(timeoutCts.Token);

Commands\LogsCommandTests.cs (4)

1465var initialLog = await logLines.Reader.ReadAsync().AsTask().DefaultTimeout(); 1472var followLog = await logLines.Reader.ReadAsync().AsTask().DefaultTimeout(); 1484await logLines.Reader.Completion.DefaultTimeout(); 1485Assert.False(logLines.Reader.TryRead(out _));

TestServices\TestAuxiliaryBackchannelMonitor.cs (1)

46await foreach (var _ in _connectionChanges.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

ActivityNotifier.cs (1)

41await foreach (var activity in _activityChannel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

MetricsChannel.cs (1)

23public ChannelReader<string> Reader => _channel.Reader;

Api\TelemetryApiService.cs (1)

543await signal.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);

Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (4)

252while (channel.Reader.TryRead(out var pendingSpan)) 260await foreach (var span in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 307while (channel.Reader.TryRead(out var pendingLog)) 316await foreach (var log in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

ServiceClient\DashboardClient.cs (3)

712await foreach (var update in _incomingInteractionChannel.Reader.ReadAllAsync(cts.Token).ConfigureAwait(false)) 919await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken: enumeratorCancellationToken).ConfigureAwait(false)) 972await foreach (var batch in channel.Reader.ReadAllAsync(combinedTokens.Token).ConfigureAwait(false))

ServiceClient\SqliteResourceRepository.cs (2)

148await foreach (var lines in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 477await foreach (var changes 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))

Telemetry\DashboardTelemetrySender.cs (3)

51while (await _channel.Reader.WaitToReadAsync().ConfigureAwait(false)) 53while (_channel.Reader.TryRead(out var operation)) 107while (_channel.Reader.TryRead(out _))

Interactions\InteractionsProviderTests.cs (5)

128Assert.Same(request, await liveRequestsChannel.Reader.ReadAsync().AsTask().DefaultTimeout()); 129Assert.False(selectedRequestsChannel.Reader.TryRead(out _)); 283var update = await sendInteractionUpdatesChannel.Reader.ReadAsync(); 347var update = await sendInteractionUpdatesChannel.Reader.ReadAsync(); 616var update = await sendInteractionUpdatesChannel.Reader.ReadAsync();

Pages\ConsoleLogsTests.cs (3)

139var subscribedResourceName1 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout(); 165var subscribedResourceName2 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout(); 169Assert.False(await subscribedResourceNamesChannel.Reader.WaitToReadAsync().DefaultTimeout());

tests\Shared\TestDashboardClient.cs (5)

80return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask(); 97await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 112await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 137await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 157await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))

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();

ResourceOutgoingPeerResolverTests.cs (9)

295Assert.False(resultChannel.Reader.TryRead(out _)); 304var readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 313readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 323readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 336Assert.False(await resultChannel.Reader.WaitToReadAsync().DefaultTimeout()); 341await foreach (var item in sourceChannel.Reader.ReadAllAsync(cancellationToken)) 366subscribeResult.SetResult(new ResourceViewModelSubscription([], sourceChannel.Reader.ReadAllAsync())); 386sourceChannel.Reader.ReadAllAsync())); 412subscribeResult.SetResult(new ResourceViewModelSubscription([], sourceChannel.Reader.ReadAllAsync()));

Telemetry\ComponentTelemetryContextTests.cs (9)

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)

1002var read1 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 1023var read2 = await resultChannel.Reader.ReadAsync().DefaultTimeout();

tests\Shared\TestDashboardClient.cs (5)

80return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask(); 97await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 112await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 137await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 157await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))

ApplicationModel\ResourceLoggerService.cs (2)

251await foreach (var entry in channel.Reader.ReadAllAsync(linkedCts.Token).ConfigureAwait(false)) 338await foreach (var item in channel.Reader.ReadAllAsync().ConfigureAwait(false))

ApplicationModel\ResourceNotificationService.cs (1)

793await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Backchannel\AppHostRpcTarget.cs (2)

61await foreach (var entry in AsyncEnumerableUtils.ReadUntilCancelledAsync(channel.Reader.ReadAllAsync(linkedToken), linkedToken).ConfigureAwait(false)) 90publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(linkedToken).ConfigureAwait(false);

Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)

1687await foreach (var logLine in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Dcp\DcpResourceWatcher.cs (1)

152await foreach (var entry in _logInformationChannel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))

Devcontainers\DevcontainerSettingsWriter.cs (1)

69var reader = _portUpdates.Reader;

InteractionService.cs (1)

669await 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))

AzureProvisioningController.cs (2)

1490await foreach (var operation in _operationChannel.Reader.ReadAllAsync(stoppingToken).ConfigureAwait(false)) 1514while (_operationChannel.Reader.TryRead(out var operation))

AzureDeployerTests.cs (14)

AzureEnvironmentResourceExtensionsTests.cs (12)

ProvisioningContextProviderTests.cs (8)

DevTunnelResourceBuilderExtensionsTests.cs (3)

476var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 528var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 576var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();

FoundryExtensions.cs (1)

359await foreach (var progress in progressChannel.Reader.ReadAllAsync(ct).ConfigureAwait(false))

AtsExportsTests.cs (2)

93var data = await interactionService.Interactions.Reader.ReadAsync(); 135var data = await interactionService.Interactions.Reader.ReadAsync();

AtsInteractionExportsTests.cs (2)

29var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 56var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout();

Backchannel\BackchannelLoggerProviderTests.cs (6)

137Assert.True(channel1.Reader.TryRead(out var entry1a)); 139Assert.True(channel1.Reader.TryRead(out var entry1b)); 142Assert.True(channel2.Reader.TryRead(out var entry2a)); 144Assert.True(channel2.Reader.TryRead(out var entry2b)); 151await channel1.Reader.Completion; 152await channel2.Reader.Completion;

Cli\CliOrphanDetectorTests.cs (8)

Dashboard\DashboardEventHandlersTests.cs (2)

67var logContext = await logChannel.Reader.ReadAsync().DefaultTimeout(); 139var logContext = await logChannel.Reader.ReadAsync().DefaultTimeout();

Dcp\DcpExecutorTests.cs (8)

162await foreach (var item in channel.Reader.ReadAllAsync()) 2128var followStdErrPipe = await followStdErrPipeChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3328await foreach (var item in logStreamPipesChannel.Reader.ReadAllAsync()) 3795var allocatedPort = await allocatedPortChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3796var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3844var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3926var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3968var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().DefaultTimeout();

Dcp\DcpHostNotificationTests.cs (13)

Dcp\TestKubernetesService.cs (1)

300var (evtType, res) = await chan.Reader.ReadAsync(cancellationToken);

DistributedApplicationTests.cs (2)

1229await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout(); 1239await 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)

Orchestrator\ParameterProcessorTests.cs (28)

Publishing\PipelineActivityReporterTests.cs (51)

RequiredCommandAnnotationTests.cs (4)

403var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 434Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 459var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 467Assert.False(testInteractionService.Interactions.Reader.TryRead(out _));

ResourceCommandServiceTests.cs (7)

161await foreach (var resourceName in commandResourcesChannel.Reader.ReadAllAsync().DefaultTimeout()) 203await foreach (var resourceName in commandResourcesChannel.Reader.ReadAllAsync().DefaultTimeout()) 1298var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1370var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1427Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 1753var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1806var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout();

VersionChecking\VersionCheckServiceTests.cs (12)

39var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 103Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 133var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 176var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 184Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 219Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 248Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 285Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 289var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 319var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 348var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 376var interaction = await interactionService.Interactions.Reader.ReadAsync().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))

DcpUpstreamAdapter.cs (2)

114if (!await _outputChannel.Reader.WaitToReadAsync(ct).ConfigureAwait(false)) 118if (!_outputChannel.Reader.TryRead(out var first))

Commands\Test\MTP\TestApplicationActionQueue.cs (1)

88await foreach (var nonParallelizedGroup in _channel.Reader.ReadAllAsync(_cancellationToken))

src\sdk\src\Cli\dotnet\Commands\Test\MTP\TestApplicationActionQueue.cs (1)

88await foreach (var nonParallelizedGroup in _channel.Reader.ReadAllAsync(_cancellationToken))

UI\SpectreBuildParametersSelectionPrompt.cs (2)

128=> _channel.Reader.TryPeek(out _); 134=> await _channel.Reader.ReadAsync(cancellationToken);

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)

57return channel.Reader.ReadAllAsync(cancellationToken);

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);

Connection\DirectTlsConnectionListener.cs (3)

165while (await _readyConnections.Reader.WaitToReadAsync(cancellationToken)) 167if (_readyConnections.Reader.TryRead(out var connection)) 195while (_readyConnections.Reader.TryRead(out var connection))

Internal\NamedPipeConnectionListener.cs (2)

149while (await _acceptedQueue.Reader.WaitToReadAsync(cancellationToken)) 151if (_acceptedQueue.Reader.TryRead(out var connection))

HubConnection.cs (1)

1922connectionState.InvocationMessageReceiveTask = StartProcessingInvocationMessages(invocationMessageChannel.Reader);

HubConnectionExtensions.StreamAsChannelAsync.cs (1)

282return outputChannel.Reader;

Internal\InvocationRequest.cs (1)

95public ChannelReader<object?> Result => _channel.Reader;

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 _);

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)

149return _channel.Reader.ReadAllAsync(); 153return _channel.Reader;

AssemblyDependency\Node\RarNodeBuildEngine.cs (2)

120int eventCount = await _eventCountChannel.Reader.ReadAsync(cancellationToken).ConfigureAwait(false); 130BuildEventArgs buildEventArgs = await _eventChannel.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);

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)

57return channel.Reader.ReadAllAsync(cancellationToken);

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)

57return channel.Reader.ReadAllAsync(cancellationToken);

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)

57return channel.Reader.ReadAllAsync(cancellationToken);

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)

57return channel.Reader.ReadAllAsync(cancellationToken);

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)

57return channel.Reader.ReadAllAsync(cancellationToken);

Util\FSWGen.cs (2)

60var completion = _channel!.Reader.Completion.ContinueWith((t) => WhenAnyResult.Completion); 62var readOne = _channel!.Reader.ReadAsync(cancellationToken).AsTask();

Aspire\AspireServiceFactory.cs (1)

183await foreach (var line in outputChannel.Reader.ReadAllAsync(cancellationToken))

ServiceEndpointResolverTests.cs (1)

275var next = await channel.Reader.ReadAsync(CancellationToken.None);

Transforms\RowShufflingTransformer.cs (3)

571while (await _toProduceChannel.Reader.WaitToReadAsync().ConfigureAwait(false)) 574if (!_toProduceChannel.Reader.TryRead(out requested)) 637ValueTask<int> readTask = _toConsumeChannel.Reader.ReadAsync();

AsyncSweeper.cs (1)

282return await _paramChannel.Reader.ReadAsync(_cts.Token);

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)

57return channel.Reader.ReadAllAsync(cancellationToken);

ProducerConsumer.cs (1)

30await foreach (var item in _channel.Reader.ReadAllAsync())

Program.cs (1)

317await foreach (var message in channel.Reader.ReadAllAsync(cancellationToken))

System\Diagnostics\Process.Multiplexing.cs (2)

551while (await channel.Reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false)) 553while (channel.Reader.TryRead(out ProcessOutputLine line))

System\IO\FileSystemWatcher.Linux.cs (1)

1109await foreach (WatcherEvent @event in _eventQueue.Reader.ReadAllAsync().ConfigureAwait(false))

System\Net\Http\SocketsHttpHandler\Http2Connection.cs (2)

1231while (await _writeChannel.Reader.WaitToReadAsync().ConfigureAwait(false)) 1233while (_writeChannel.Reader.TryRead(out WriteQueueEntry? writeEntry))

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\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}";