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);
629 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)
202await 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 (47)
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 (9)
128Assert.Same(request, await liveRequestsChannel.Reader.ReadAsync().AsTask().DefaultTimeout()); 129Assert.False(selectedRequestsChannel.Reader.TryRead(out _)); 189await sendInteractionUpdatesChannel.Reader.ReadAsync(); 298var update = await sendInteractionUpdatesChannel.Reader.ReadAsync(); 361var update = await sendInteractionUpdatesChannel.Reader.ReadAsync(); 454Assert.False(sendInteractionUpdatesChannel.Reader.TryRead(out _)); 464var update = await sendInteractionUpdatesChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 573var update = await sendInteractionUpdatesChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 766var 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\NavigationAvailabilityProviderTests.cs (3)
65await reported.Reader.ReadAsync().AsTask().WaitAsync(DefaultWaitTimeout)); 70await reported.Reader.ReadAsync().AsTask().WaitAsync(DefaultWaitTimeout)); 75await reported.Reader.ReadAsync().AsTask().WaitAsync(DefaultWaitTimeout));
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)
130while (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)
82Assert.True(fixture.LogChannel.Reader.TryRead(out var initializeLog)); 99Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 111Assert.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)
365Assert.Equal(closed, await closes.Reader.ReadAsync().AsTask().DefaultTimeout()); 389Assert.Equal("replacement", await closes.Reader.ReadAsync().AsTask().DefaultTimeout()); 407Assert.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)
1710await 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)
719await 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)
133var interaction = await interactionService.Interactions.Reader.ReadAsync(); 242var tenantInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 258var subscriptionInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 276var resourceGroupInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 294var locationInteraction = await testInteractionService.Interactions.Reader.ReadAsync(); 1002var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1044Assert.Equal(0, testInteractionService.Interactions.Reader.Count); 1073var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1240Assert.Equal(0, testInteractionService.Interactions.Reader.Count); 1265var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 1310var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 2099var parameterInputs = await testInteractionService.Interactions.Reader.ReadAsync(); 2165if (testInteractionService.Interactions.Reader.Count > 0) 2168var interaction = await testInteractionService.Interactions.Reader.ReadAsync(); 2172Assert.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)
617var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 671var interaction = await interactionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 721var 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)
707await 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 (221)
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)
1837var log = await logs.Reader.ReadAsync().AsTask().DefaultTimeout(); 1873var log = await logs.Reader.ReadAsync().AsTask().DefaultTimeout();
Dcp\DcpExecutorTests.cs (12)
260await endpointEventsProcessed.Reader.ReadAsync().AsTask().DefaultTimeout(); 269await endpointEventsProcessed.Reader.ReadAsync().AsTask().DefaultTimeout(); 515await foreach (var item in channel.Reader.ReadAllAsync()) 2577var followStdErrPipe = await followStdErrPipeChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3065var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 3107var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 3890await foreach (var item in logStreamPipesChannel.Reader.ReadAllAsync()) 4515var allocatedPort = await allocatedPortChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4516var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4564var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4646var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4688var 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(); 925Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 962Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 1010var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout(); 1060Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 1105Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 1158var interaction = await interactionService.Interactions.Reader.ReadAsync(cts.Token).DefaultTimeout();
Dcp\KubernetesServiceTests.cs (3)
239startedResourceName = await requestsStarted.Reader.ReadAsync(cts.Token).DefaultTimeout(); 245watchedResourceName = await requestsStarted.Reader.ReadAsync(cts.Token).DefaultTimeout(); 254var nextResourceName = await requestsStarted.Reader.ReadAsync(cts.Token).DefaultTimeout();
Dcp\TestKubernetesService.cs (1)
333var (evtType, res) = await chan.Reader.ReadAsync(cancellationToken);
DistributedApplicationTests.cs (2)
1288await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout(); 1298await 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(); 1033var interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 1042interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 1088var interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 1101interaction = await updates.Reader.ReadAsync().DefaultTimeout(); 1108interaction = await updates.Reader.ReadAsync().DefaultTimeout();
Orchestrator\ParameterProcessorTests.cs (63)
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(); 1322var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1325var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1369var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1372var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1399var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1403var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1427var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1470var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1625var notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1627var prompt = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1649var notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1651var prompt = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1851var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1854var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1892var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1895var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1936var messageBarInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1939var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2022var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2027var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2052Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 2117notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2169interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2171interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2180interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2182interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2285var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2335var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2373var interaction = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2420var notification = await interactionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2460var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2464var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2511var setInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2521var deleteInteraction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 2533var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2537var 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(); 1474var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1531Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 1878var interaction = await testInteractionService.Interactions.Reader.ReadAsync().DefaultTimeout(); 1931var 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)
177return 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}";