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);
617 references to Reader
aspire (14)
Backchannel\AuxiliaryBackchannelMonitor.cs (1)
121await foreach (var _ in connectionChanges.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Backchannel\ResourceSnapshotWatcher.cs (1)
243await foreach (var _ in updateSignal.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Backchannel\TrayWatchStream.cs (5)
75pendingRead = updates.Reader.WaitToReadAsync(token).AsTask(); 94if (updates.Reader.TryRead(out var update)) 103pendingRead = updates.Reader.WaitToReadAsync(token).AsTask(); 284healthChanges.Reader.TryRead(out _); 285pendingHealthRead ??= healthChanges.Reader.WaitToReadAsync(token).AsTask();
Commands\PsCommand.cs (1)
266await foreach (var update in updates.Reader.ReadAllAsync(followCancellationToken).ConfigureAwait(false))
Diagnostics\FileLoggerProvider.cs (1)
180await foreach (var message in _channel.Reader.ReadAllAsync())
Interaction\ExtensionInteractionService.cs (2)
691while (await _extensionTaskChannel.Reader.WaitToReadAsync(_cancellationToken).ConfigureAwait(false)) 695var 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))
aspire-tray (1)
NativeSmokeHarness.cs (1)
432await foreach (var snapshot in _snapshots.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Aspire.Cli.Tests (31)
Backchannel\ResourceSnapshotWatcherTests.cs (1)
542ReadSnapshotsAndSignalFirstApplied(source.Reader, firstSnapshotApplied, cancellationToken)
Backchannel\TrayWatchStreamTests.cs (21)
113var monitor = new TestAuxiliaryBackchannelMonitor { WatchConnectionsHandler = token => snapshots.Reader.ReadAllAsync(token) }; 465var initial = await messages.Reader.ReadAsync().AsTask().DefaultTimeout(); 470var retried = await messages.Reader.ReadAsync().AsTask().DefaultTimeout(); 595Assert.Equal((second + 1) * TrayWatchStream.MaximumConcurrentDashboardLookups, await batches.Reader.ReadAsync().AsTask().DefaultTimeout()); 621var monitor = new TestAuxiliaryBackchannelMonitor { WatchConnectionsHandler = token => snapshots.Reader.ReadAllAsync(token) }; 650var initial = await messages.Reader.ReadAsync().AsTask().DefaultTimeout(); 668var snapshot = await messages.Reader.ReadAsync().AsTask().DefaultTimeout(); 744var monitor = new TestAuxiliaryBackchannelMonitor { WatchConnectionsHandler = token => snapshots.Reader.ReadAllAsync(token) }; 792var message = await messages.Reader.ReadAsync().AsTask().DefaultTimeout(); 803await foreach (var resource in resourceUpdates.Reader.ReadAllAsync(token)) 825connection.WatchResourceSnapshotsHandler = (_, token) => resourceUpdates.Reader.ReadAllAsync(token); 838Assert.Equal("healthy", Assert.Single((await messages.Reader.ReadAsync().AsTask().DefaultTimeout()).AppHosts!).Health); 841var message = await messages.Reader.ReadAsync().AsTask().DefaultTimeout(); 870var monitor = new TestAuxiliaryBackchannelMonitor { WatchConnectionsHandler = token => snapshots.Reader.ReadAllAsync(token) }; 881var first = Assert.Single((await messages.Reader.ReadAsync().AsTask().DefaultTimeout()).AppHosts!); 886Assert.Empty((await messages.Reader.ReadAsync().AsTask().DefaultTimeout()).AppHosts!); 891var second = Assert.Single((await messages.Reader.ReadAsync().AsTask().DefaultTimeout()).AppHosts!); 957Assert.Equal("healthy", Assert.Single((await messages.Reader.ReadAsync().DefaultTimeout()).AppHosts!).Health); 961Assert.Empty((await messages.Reader.ReadAsync().DefaultTimeout()).AppHosts!); 964var host = Assert.Single((await messages.Reader.ReadAsync().DefaultTimeout()).AppHosts!); 1004await foreach (var connections in snapshots.Reader.ReadAllAsync(token))
Commands\AgentMcpCommandTests.cs (4)
1074var notification = await notificationChannel.Reader.ReadAsync(ctx.Cts.Token).AsTask().DefaultTimeout(); 1257await notificationChannel.Reader.ReadAsync(timeoutCts.Token); 1324var notification = await notificationChannel.Reader.ReadAsync(ctx.Cts.Token).AsTask().DefaultTimeout(); 1376await notificationChannel.Reader.ReadAsync(timeoutCts.Token);
Commands\LogsCommandTests.cs (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)
59await foreach (var _ in _connectionChanges.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
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)
Api\TelemetryApiService.cs (1)
543await signal.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (4)
251while (channel.Reader.TryRead(out var pendingSpan)) 259await foreach (var span in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 306while (channel.Reader.TryRead(out var pendingLog)) 315await foreach (var log in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
ServiceClient\DashboardClient.cs (3)
760await foreach (var update in _incomingInteractionChannel.Reader.ReadAllAsync(cts.Token).ConfigureAwait(false)) 980await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken: enumeratorCancellationToken).ConfigureAwait(false)) 1033await foreach (var batch in channel.Reader.ReadAllAsync(combinedTokens.Token).ConfigureAwait(false))
ServiceClient\SqliteResourceRepository.cs (2)
154await foreach (var lines in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 484await 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))
Aspire.Dashboard.Components.Tests (42)
Controls\TerminalWindowButtonTests.cs (7)
234Assert.False(checkedKeys.Reader.TryPeek(out _)); 253Assert.False(checkedKeys.Reader.TryPeek(out _)); 255Assert.Equal(["first", "inactive"], await checkedKeys.Reader.ReadAsync().AsTask().DefaultTimeout()); 258Assert.Equal(["new"], await checkedKeys.Reader.ReadAsync().AsTask().DefaultTimeout()); 322Assert.Equal(["first"], await failedKeys.Reader.ReadAsync().AsTask().DefaultTimeout()); 325Assert.Equal(["new"], await failedKeys.Reader.ReadAsync().AsTask().DefaultTimeout()); 327Assert.False(failedKeys.Reader.TryPeek(out _));
Interactions\InteractionsProviderTests.cs (7)
129Assert.Same(request, await liveRequestsChannel.Reader.ReadAsync().AsTask().DefaultTimeout()); 130Assert.False(selectedRequestsChannel.Reader.TryRead(out _)); 190await sendInteractionUpdatesChannel.Reader.ReadAsync(); 299var update = await sendInteractionUpdatesChannel.Reader.ReadAsync(); 362var update = await sendInteractionUpdatesChannel.Reader.ReadAsync(); 471var update = await sendInteractionUpdatesChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 664var update = await sendInteractionUpdatesChannel.Reader.ReadAsync();
Interactions\InteractionsProviderTests.Terminal.cs (10)
50var (content, parameters) = await shown.Reader.ReadAsync().AsTask().DefaultTimeout(); 68var request = await requests.Reader.ReadAsync().AsTask().DefaultTimeout(); 79Assert.False(requests.Reader.TryRead(out _)); 102Assert.IsType<InteractionsProgressDialogViewModel>((await shown.Reader.ReadAsync().AsTask().DefaultTimeout()).Content); 127Assert.False(shown.Reader.TryRead(out _)); 130var (content, _) = await shown.Reader.ReadAsync().AsTask().DefaultTimeout(); 143Assert.False(shown.Reader.TryRead(out _)); 146var (inputContent, inputParameters) = await shown.Reader.ReadAsync().AsTask().DefaultTimeout(); 151Assert.False(requests.Reader.TryRead(out _)); 152Assert.False(shown.Reader.TryRead(out _));
Layout\TerminalDockInitializationTests.cs (3)
46Assert.Same(update, await processed.Reader.ReadAsync().AsTask().DefaultTimeout()); 58await processed.Reader.ReadAsync().AsTask().DefaultTimeout(); 72await processed.Reader.ReadAsync().AsTask().DefaultTimeout();
Layout\TerminalDockTelemetryTests.cs (1)
131while (fixture.LogChannel.Reader.TryRead(out var log))
Layout\TerminalDockWindowTrackingTests.cs (2)
199await started.Reader.ReadAsync().AsTask().DefaultTimeout(); 211await started.Reader.ReadAsync().AsTask().DefaultTimeout();
Pages\ConsoleLogsTests.cs (3)
138var subscribedResourceName1 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout(); 165var subscribedResourceName2 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout(); 169Assert.False(await subscribedResourceNamesChannel.Reader.WaitToReadAsync().DefaultTimeout());
Pages\ResourcesTests.cs (3)
61Assert.True(fixture.LogChannel.Reader.TryRead(out var initializeLog)); 78Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 90Assert.False(fixture.LogChannel.Reader.TryPeek(out _));
tests\Shared\TestDashboardClient.cs (6)
113return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask(); 134await foreach (var update in provider().Reader.ReadAllAsync(cancellationToken)) 171await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 186await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 219await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 244await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))
Aspire.Dashboard.Playwright.Tests (11)
Integration\Playwright\Infrastructure\TestTerminalConnectionResolver.cs (2)
31_connections.Reader.ReadAsync(cancellationToken).AsTask(); 43while (_connections.Reader.TryRead(out _))
Integration\Playwright\TerminalDockTests.cs (3)
359Assert.Equal(closed, await closes.Reader.ReadAsync().AsTask().DefaultTimeout()); 383Assert.Equal("replacement", await closes.Reader.ReadAsync().AsTask().DefaultTimeout()); 401Assert.Equal("first", await closes.Reader.ReadAsync().AsTask().DefaultTimeout());
tests\Shared\TestDashboardClient.cs (6)
113return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask(); 134await foreach (var update in provider().Reader.ReadAllAsync(cancellationToken)) 171await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 186await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 219await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 244await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))
Aspire.Dashboard.Tests (137)
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();
Integration\StartupTests.cs (4)
1200Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 1206Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 1266Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 1281Assert.False(fixture.LogChannel.Reader.TryPeek(out _));
Model\DashboardClientTests.cs (23)
56new AsyncStreamReader<TerminalServerFrame>(channel: channel.Reader), 127new AsyncStreamReader<TerminalServerFrame>(channel: channel.Reader), 150new AsyncStreamReader<TerminalServerFrame>(channel: channel.Reader), 175new AsyncStreamReader<TerminalServerFrame>(channel: channel.Reader), 495client.SetDashboardServiceClient(new MockDashboardServiceClient { ResourceUpdatesChannel = updates.Reader }); 544return resources.Reader; 547? firstInteractions.Reader : secondInteractions.Reader 6211 => first.Reader, 6222 => second.Reader, 623_ => third.Reader 628Assert.Equal(1, await subscriptionsStarted.Reader.ReadAsync().AsTask().DefaultTimeout()); 635Assert.Equal(2, await subscriptionsStarted.Reader.ReadAsync().AsTask().DefaultTimeout()); 644Assert.Equal(3, await subscriptionsStarted.Reader.ReadAsync().AsTask().DefaultTimeout()); 1108ResourceUpdatesChannel = Channel.CreateUnbounded<WatchResourcesUpdate>().Reader, 1109TerminalUpdatesProvider = () => Interlocked.Increment(ref subscriptions) == 1 ? first.Reader : second.Reader, 1147Assert.True(await disposed.Reader.ReadAsync().AsTask().DefaultTimeout()); 1149Assert.True(await disposed.Reader.ReadAsync().AsTask().DefaultTimeout()); 1163ResourceUpdatesChannel = Channel.CreateUnbounded<WatchResourcesUpdate>().Reader, 1164TerminalUpdatesProvider = () => channel.Reader, 1216ResourceUpdatesChannel = Channel.CreateUnbounded<WatchResourcesUpdate>().Reader, 1220return channel.Reader;
Model\DashboardCommandExecutorTests.cs (2)
98Assert.True(fixture.ActivityChannel.Reader.TryRead(out var activity)); 114Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _));
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\AspireTelemetryBaseTests.cs (8)
42Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 61Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 62Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 84Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 90Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 107Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 117Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 125Assert.False(fixture.LogChannel.Reader.TryPeek(out _));
Telemetry\ComponentTelemetryContextTests.cs (11)
24Assert.True(fixture.LogChannel.Reader.TryRead(out var initializeEvent)); 30Assert.True(fixture.LogChannel.Reader.TryRead(out var parametersUpdateEvent)); 35Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 38Assert.True(fixture.LogChannel.Reader.TryRead(out parametersUpdateEvent)); 43Assert.True(fixture.LogChannel.Reader.TryRead(out var disposeEvent)); 45Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 46Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 62Assert.False(fixture.LogChannel.Reader.TryRead(out _)); 87Assert.False(fixture.LogChannel.Reader.TryRead(out _)); 91Assert.False(fixture.LogChannel.Reader.TryRead(out _)); 92Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _));
Telemetry\DashboardStartupTelemetryTests.cs (9)
46Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 65Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 87Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 92Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 112Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 138Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 142Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 171Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 176Assert.False(fixture.LogChannel.Reader.TryPeek(out _));
Telemetry\DashboardTelemetryLogExportTests.cs (4)
83Assert.True(exporter.LogChannel.Reader.TryRead(out var log)); 95Assert.False(exporter.LogChannel.Reader.TryPeek(out _)); 104Assert.True(exporter.LogChannel.Reader.TryRead(out var shutdownLog)); 108Assert.False(exporter.LogChannel.Reader.TryPeek(out _));
Telemetry\DashboardTelemetryManagerTests.cs (1)
49Assert.True(exporter.LogChannel.Reader.TryRead(out var log));
Telemetry\DashboardTelemetryMetadataTests.cs (5)
67Assert.True(fixture.LogChannel.Reader.TryRead(out var startup)); 73Assert.True(fixture.LogChannel.Reader.TryRead(out var usage)); 83Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 133Assert.True(fixture.LogChannel.Reader.TryRead(out var record)); 141Assert.False(fixture.LogChannel.Reader.TryPeek(out _));
Telemetry\DashboardTelemetryServiceTests.cs (35)
34Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 38Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 42Assert.True(fixture.ActivityChannel.Reader.TryRead(out var recorded)); 84Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 112Assert.True(fixture.LogChannel.Reader.TryRead(out var initializeEvent)); 113Assert.True(fixture.LogChannel.Reader.TryRead(out var parametersEvent)); 124Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 125Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 141Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 150Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 156Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 169Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 171Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 190Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 195Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 196Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 215Assert.True(fixture.LogChannel.Reader.TryRead(out var errorLog)); 228Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 233Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 236Assert.True(fixture.ActivityChannel.Reader.TryRead(out var recorded)); 239Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 240Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 256Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 263Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 264Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 282Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 287Assert.True(fixture.LogChannel.Reader.TryRead(out var errorLog)); 297Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 312Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 319Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 320Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 338Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 339Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 375Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 384Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _));
Telemetry\TelemetryErrorRecorderTests.cs (3)
140Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 167Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 169while (fixture.LogChannel.Reader.TryRead(out var log))
Telemetry\TelemetryLoggerProviderTests.cs (9)
34Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 35Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 37Assert.False(fixture.LogChannel.Reader.TryPeek(out _)); 62Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 67Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 71Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 76Assert.False(fixture.ActivityChannel.Reader.TryPeek(out _)); 77Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 81Assert.False(fixture.LogChannel.Reader.TryPeek(out _));
TelemetryRepositoryTests\LogTests.cs (2)
1002var read1 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 1023var read2 = await resultChannel.Reader.ReadAsync().DefaultTimeout();
tests\Shared\TestDashboardClient.cs (6)
113return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask(); 134await foreach (var update in provider().Reader.ReadAllAsync(cancellationToken)) 171await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 186await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 219await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken)) 244await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken))
Aspire.Hosting (15)
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)
830await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
ApplicationModel\TerminalService.cs (3)
339while (await channel.Reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false)) 346channel.Reader.TryRead(out change); 445while (channel.Reader.TryRead(out var pending))
Backchannel\AppHostRpcTarget.cs (2)
63await foreach (var entry in AsyncEnumerableUtils.ReadUntilCancelledAsync(channel.Reader.ReadAllAsync(linkedToken), linkedToken).ConfigureAwait(false)) 92publishingActivity = await activityReporter.ActivityItemUpdated.Reader.ReadAsync(linkedToken).ConfigureAwait(false);
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
1709await foreach (var logLine in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Dcp\DcpResourceWatcher.cs (1)
181await foreach (var entry in _logInformationChannel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Dcp\KubernetesService.cs (1)
365await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Devcontainers\DevcontainerSettingsWriter.cs (1)
69var reader = _portUpdates.Reader;
InteractionService.cs (1)
712await 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 (2)
AzureProvisioningController.cs (2)
1535await foreach (var operation in _operationChannel.Reader.ReadAllAsync(stoppingToken).ConfigureAwait(false)) 1559while (_operationChannel.Reader.TryRead(out var operation))
Aspire.Hosting.Azure.Tests (40)
AzureDeployerTests.cs (15)
132var interaction = await interactionService.Interactions.Reader.ReadAsync(); 241var tenantInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 257var subscriptionInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 275var resourceGroupInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 293var locationInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 1001var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1043Assert.Equal(0, testInteractionService.Interactions.Reader.Count); 1072var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1239Assert.Equal(0, testInteractionService.Interactions.Reader.Count); 1264var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1309var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 2098var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 2164if (testInteractionService.Interactions.Reader.Count > 0) 2167var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 2171Assert.Equal(0, testInteractionService.Interactions.Reader.Count);
AzureEnvironmentResourceExtensionsTests.cs (12)
720var interaction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().WaitAsync(s_testSynchronizationTimeout); 748var notification = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().WaitAsync(s_testSynchronizationTimeout); 759var inputs = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().WaitAsync(s_testSynchronizationTimeout); 770var repeatedNotification = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().WaitAsync(s_testSynchronizationTimeout); 3110var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 3166Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 3284var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 3415var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 3541var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 3604var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 3777Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 4452var interaction = await testInteractionService.Interactions.Reader.ReadAsync();
ProvisioningContextProviderTests.cs (13)
37var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 53Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 84Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 99var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 159var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token); 542var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 638var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 700var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 843var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 890var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 934var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 993var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 1037var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync();
Aspire.Hosting.DevTunnels (1)
DevTunnelMonitor.cs (1)
731await foreach (var operation in _operations.Reader.ReadAllAsync().ConfigureAwait(false))
Aspire.Hosting.DevTunnels.Tests (5)
DevTunnelMonitorTests.cs (2)
133Assert.Equal(TimeSpan.FromSeconds(1), await time.ScheduledDelays.Reader.ReadAsync().AsTask().DefaultTimeout()); 676var notification = await test.Interaction.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();
DevTunnelResourceBuilderExtensionsTests.cs (3)
580var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 632var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 680var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();
Aspire.Hosting.Foundry (1)
FoundryExtensions.cs (1)
473await foreach (var progress in progressChannel.Reader.ReadAllAsync(ct).ConfigureAwait(false))
Aspire.Hosting.Native.Core (1)
Diagnostics\OperationEventSource.cs (1)
92public ChannelReader<OperationEvent> Reader => _channel.Reader;
Aspire.Hosting.Native.Core.Tests (5)
SocketConnectionListenerTests.cs (4)
49await connected.Reader.ReadAsync(timeout.Token); 51await connected.Reader.ReadAsync(timeout.Token); 110await connected.Reader.ReadAsync(timeout.Token); 112await connected.Reader.ReadAsync(timeout.Token);
TestServices\RecordingBackchannelRpc.cs (1)
17_connections.Reader.ReadAsync(cancellationToken).AsTask();
Aspire.Hosting.Native.Server (1)
Api\PipelineApi.cs (1)
85_activities.Reader.ReadAllAsync(cancellationToken);
Aspire.Hosting.RemoteHost (1)
src\Shared\ChildProcess.cs (1)
703await foreach (var line in lines.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.RemoteHost.Tests (2)
AtsExportsTests.cs (2)
93var data = await interactionService.Interactions.Reader.ReadAsync(); 135var data = await interactionService.Interactions.Reader.ReadAsync();
Aspire.Hosting.Tests (214)
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)
162Assert.Equal(1, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 166Assert.Equal(2, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 170Assert.Equal(3, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 237Assert.Equal(1, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 240Assert.Equal(2, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 243Assert.Equal(3, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 246Assert.Equal(4, await processRunningChannel.Reader.ReadAsync().DefaultTimeout()); 249Assert.Equal(5, await processRunningChannel.Reader.ReadAsync().DefaultTimeout());
Dashboard\DashboardEventHandlersTests.cs (2)
69var logContext = await logChannel.Reader.ReadAsync().DefaultTimeout(); 141var logContext = await logChannel.Reader.ReadAsync().DefaultTimeout();
Dashboard\DashboardServiceTests.cs (2)
1792var log = await logs.Reader.ReadAsync().AsTask().DefaultTimeout(); 1828var log = await logs.Reader.ReadAsync().AsTask().DefaultTimeout();
Dcp\DcpExecutorTests.cs (12)
259await endpointEventsProcessed.Reader.ReadAsync().AsTask().DefaultTimeout(); 268await endpointEventsProcessed.Reader.ReadAsync().AsTask().DefaultTimeout(); 514await foreach (var item in channel.Reader.ReadAllAsync()) 2576var followStdErrPipe = await followStdErrPipeChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3064var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 3106var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 3889await foreach (var item in logStreamPipesChannel.Reader.ReadAllAsync()) 4514var allocatedPort = await allocatedPortChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4515var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4563var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4645var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4687var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().DefaultTimeout();
Dcp\DcpHostNotificationTests.cs (13)
112var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 156var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 208Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 253Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 299var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 354var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 421var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 848Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 885Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 933var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 983Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 1028Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 1081var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout();
Dcp\KubernetesServiceTests.cs (3)
198startedResourceName = await requestsStarted.Reader.ReadAsync(cts.Token).DefaultTimeout(); 204watchedResourceName = await requestsStarted.Reader.ReadAsync(cts.Token).DefaultTimeout(); 213var nextResourceName = await requestsStarted.Reader.ReadAsync(cts.Token).DefaultTimeout();
Dcp\TestKubernetesService.cs (1)
333var (evtType, res) = await chan.Reader.ReadAsync(cancellationToken);
DistributedApplicationTests.cs (2)
1233await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout(); 1243await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout();
DotnetProgramPublishingTests.cs (3)
390var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 399Assert.False(interactions.Interactions.Reader.TryRead(out _)); 419Assert.False(interactions.Interactions.Reader.TryRead(out _));
Health\ResourceHealthCheckServiceTests.cs (5)
171var e1 = await channel.Reader.ReadAsync().DefaultTimeout(); 199var e2 = await channel.Reader.ReadAsync().DefaultTimeout(); 319var firstCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout(); 322var secondCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout(); 325var thirdCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout();
InteractionServiceTests.cs (9)
138Assert.Equal(interaction1.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 143Assert.Equal(interaction2.InteractionId, (await updates.Reader.ReadAsync().DefaultTimeout()).InteractionId); 150var completedInteraction1 = await updates.Reader.ReadAsync().DefaultTimeout(); 158var completedInteraction2 = await updates.Reader.ReadAsync().DefaultTimeout(); 929var interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 938interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 984var interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 997interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 1004interaction = await updates.Reader.ReadAsync().DefaultTimeout();
Orchestrator\ParameterProcessorTests.cs (56)
141Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 160Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 174var messageBarInteraction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 178var inputsInteraction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 281var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 289var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 374var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 385Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 388Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 395var newNotification = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 425var prompt = await interactions.Interactions.Reader.ReadAsync().DefaultTimeout(); 434prompt = await interactions.Interactions.Reader.ReadAsync().DefaultTimeout(); 443Assert.False(interactions.Interactions.Reader.TryRead(out _)); 453prompt = await interactions.Interactions.Reader.ReadAsync().DefaultTimeout(); 461prompt = await interactions.Interactions.Reader.ReadAsync().DefaultTimeout(); 468Assert.False(interactions.Interactions.Reader.TryRead(out _)); 558var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 562var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 608var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 612var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 651var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 655var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 686var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 690var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 725var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 729var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 1291var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1337var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1492var notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1494var prompt = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1516var notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1518var prompt = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1717var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1720var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1758var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1761var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1802var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1805var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1888var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1893var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1918Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 1983notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2035interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2037interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2046interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2048interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2151var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2201var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2239var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2286var notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2326var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2330var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2377var setInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2387var deleteInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2399var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2403var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();
Publishing\ContainerRuntimeReadinessTests.cs (8)
26Assert.False(interactions.Interactions.Reader.TryRead(out _)); 42Assert.False(interactions.Interactions.Reader.TryRead(out _)); 57var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 64Assert.False(interactions.Interactions.Reader.TryRead(out _)); 87var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 96Assert.False(interactions.Interactions.Reader.TryRead(out _)); 131var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 164var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout();
Publishing\PipelineActivityReporterTests.cs (51)
41var activityReader = reporter.ActivityItemUpdated.Reader; 66var activityReader = reporter.ActivityItemUpdated.Reader; 86reporter.ActivityItemUpdated.Reader.TryRead(out _); 94var activityReader = reporter.ActivityItemUpdated.Reader; 112reporter.ActivityItemUpdated.Reader.TryRead(out _); 128var activityReader = reporter.ActivityItemUpdated.Reader; 182reporter.ActivityItemUpdated.Reader.TryRead(out _); 193var activityReader = reporter.ActivityItemUpdated.Reader; 214reporter.ActivityItemUpdated.Reader.TryRead(out _); 215reporter.ActivityItemUpdated.Reader.TryRead(out _); 226var activityReader = reporter.ActivityItemUpdated.Reader; 286reporter.ActivityItemUpdated.Reader.TryRead(out _); 287reporter.ActivityItemUpdated.Reader.TryRead(out _); 299var activityReader = reporter.ActivityItemUpdated.Reader; 342var activityReader = reporter.ActivityItemUpdated.Reader; 363var activityReader = reporter.ActivityItemUpdated.Reader; 396var activityReader = reporter.ActivityItemUpdated.Reader; 566var activityReader = reporter.ActivityItemUpdated.Reader; 597var activityReader = reporter.ActivityItemUpdated.Reader; 626var activityReader = reporter.ActivityItemUpdated.Reader; 656var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 696var activity = await reporter.ActivityItemUpdated.Reader.ReadAsync().DefaultTimeout(); 725var activityReader = reporter.ActivityItemUpdated.Reader; 772reporter.ActivityItemUpdated.Reader.TryRead(out _); 782var activityReader = reporter.ActivityItemUpdated.Reader; 816var activityReader = reporter.ActivityItemUpdated.Reader; 860reporter.ActivityItemUpdated.Reader.TryRead(out _); 861reporter.ActivityItemUpdated.Reader.TryRead(out _); 873var activityReader = reporter.ActivityItemUpdated.Reader; 895reporter.ActivityItemUpdated.Reader.TryRead(out _); 896reporter.ActivityItemUpdated.Reader.TryRead(out _); 908var activityReader = reporter.ActivityItemUpdated.Reader; 932var activityReader = reporter.ActivityItemUpdated.Reader; 953var activityReader = reporter.ActivityItemUpdated.Reader; 979var activityReader = reporter.ActivityItemUpdated.Reader; 1006var activityReader = reporter.ActivityItemUpdated.Reader; 1029var activityReader = reporter.ActivityItemUpdated.Reader; 1043reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 1054var activityReader = reporter.ActivityItemUpdated.Reader; 1072reporter.ActivityItemUpdated.Reader.TryRead(out _); 1079var activityReader = reporter.ActivityItemUpdated.Reader; 1123reporter.ActivityItemUpdated.Reader.TryRead(out _); 1124reporter.ActivityItemUpdated.Reader.TryRead(out _); 1134var activityReader = reporter.ActivityItemUpdated.Reader; 1146reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 1153var activityReader = reporter.ActivityItemUpdated.Reader; 1173var activityReader = reporter.ActivityItemUpdated.Reader; 1193var activityReader = reporter.ActivityItemUpdated.Reader; 1212var activityReader = reporter.ActivityItemUpdated.Reader; 1380while (reporter.ActivityItemUpdated.Reader.TryRead(out _)) { } 1385Assert.False(reporter.ActivityItemUpdated.Reader.TryRead(out _));
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)
162await foreach (var resourceName in commandResourcesChannel.Reader.ReadAllAsync().DefaultTimeout()) 204await foreach (var resourceName in commandResourcesChannel.Reader.ReadAllAsync().DefaultTimeout()) 1299var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1473var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1530Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 1866var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1919var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout();
Terminals\TerminalServiceTests.cs (8)
65Assert.Equal(capacity, channel.Reader.Count); 68Assert.Equal(1, channel.Reader.Count); 153Assert.False(channel.Reader.TryRead(out _)); 425Assert.Equal(TerminalService.DefaultDockUpdateBufferCapacity, channel.Reader.Count); 428Assert.Equal(1, channel.Reader.Count); 462Assert.InRange(channel.Reader.Count, 1, TerminalService.DefaultDockUpdateBufferCapacity); 527channel => Assert.InRange(channel.Reader.Count, 0, TerminalService.DefaultDockUpdateBufferCapacity)); 579Assert.InRange(channel.Reader.Count, 1, TerminalService.DefaultDockUpdateBufferCapacity);
VersionChecking\VersionCheckServiceTests.cs (12)
37var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 101Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 131var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 174var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 182Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 217Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 246Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 283Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 287var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 317var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 346var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 374var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout();
Aspire.Hosting.TestUtilities (6)
Utils\Grpc\TestAsyncStreamReader.cs (2)
39if (await _channel.Reader.WaitToReadAsync(cancellationToken) && 40_channel.Reader.TryRead(out var message))
Utils\Grpc\TestServerStreamWriter.cs (3)
32return _channel.Reader.ReadAllAsync(); 37if (await _channel.Reader.WaitToReadAsync()) 39_channel.Reader.TryRead(out var message);
Utils\TestConsoleLogsService.cs (1)
28await foreach (var result in channel.Reader.ReadAllAsync(cancellationToken))
Aspire.TerminalHost (2)
DcpUpstreamAdapter.cs (2)
119if (!await _outputChannel.Reader.WaitToReadAsync(ct).ConfigureAwait(false)) 123if (!_outputChannel.Reader.TryRead(out var first))
Aspire.Tray.Tests (5)
Helpers\TestAppHostClient.cs (5)
35await foreach (var snapshot in _snapshots.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 93=> _starting.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().WaitAsync(TimeSpan.FromSeconds(10)); 96=> _finishedStarts.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().WaitAsync(TimeSpan.FromSeconds(10)); 106=> _started.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().WaitAsync(TimeSpan.FromSeconds(10)); 109=> _finished.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().WaitAsync(TimeSpan.FromSeconds(10));
dotnet-aot (1)
parent\dotnet\Commands\Test\MTP\TestApplicationActionQueue.cs (1)
116await foreach (var nonParallelizedGroup in _channel.Reader.ReadAllAsync(_cancellationToken))
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)
57return 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.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)
1929connectionState.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)
159while (await _waitForAck.Reader.WaitToReadAsync(linkedToken).ConfigureAwait(false)) 161if (_waitForAck.Reader.TryRead(out var count) && count < _bufferLimit) 170_waitForAck.Reader.TryRead(out _);
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)
159while (await _waitForAck.Reader.WaitToReadAsync(linkedToken).ConfigureAwait(false)) 161if (_waitForAck.Reader.TryRead(out var count) && count < _bufferLimit) 170_waitForAck.Reader.TryRead(out _);
StreamTracker.cs (2)
149return _channel.Reader.ReadAllAsync(); 153return _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)
57return 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)
57return 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)
57return 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)
57return 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)
57return 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.AI (1)
ChatCompletion\AnonymousDelegatingChatClient.cs (1)
162return updates.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)
57return channel.Reader.ReadAllAsync(cancellationToken);
Stress.ApiService (2)
ProducerConsumer.cs (1)
30await foreach (var item in _channel.Reader.ReadAllAsync())
Program.cs (1)
373await 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)
1109await foreach (WatcherEvent @event in _eventQueue.Reader.ReadAllAsync().ConfigureAwait(false))
System.Net.Http (2)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (2)
1231while (await _writeChannel.Reader.WaitToReadAsync().ConfigureAwait(false)) 1233while (_writeChannel.Reader.TryRead(out WriteQueueEntry? writeEntry))
System.Net.Quic (4)
System\Net\Quic\QuicConnection.cs (2)
578return await _acceptQueue.Reader.ReadAsync(cancellationToken).ConfigureAwait(false); 867while (_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}";