5 overrides of TryRead
System.Threading.Channels (5)
System\Threading\Channels\BoundedChannel.cs (1)
109public override bool TryRead([MaybeNullWhen(false)] out T item)
System\Threading\Channels\RendezvousChannel.cs (1)
81public override bool TryRead([MaybeNullWhen(false)] out T item)
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)
123public override bool TryRead([MaybeNullWhen(false)] out T item)
System\Threading\Channels\UnboundedChannel.cs (1)
109public override bool TryRead([MaybeNullWhen(false)] out T item)
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
110public override bool TryRead([MaybeNullWhen(false)] out T item)
188 references to TryRead
aspire (3)
Backchannel\TrayWatchStream.cs (2)
94if (updates.Reader.TryRead(out var update)) 284healthChanges.Reader.TryRead(out _);
src\Shared\ChannelExtensions.cs (1)
48while (!cancellationToken.IsCancellationRequested && channel.Reader.TryRead(out var log))
Aspire.Cli.Tests (1)
Commands\LogsCommandTests.cs (1)
1485Assert.False(logLines.Reader.TryRead(out _));
Aspire.Confluent.Kafka (1)
MetricsService.cs (1)
21while (channel.Reader.TryRead(out var json))
Aspire.Dashboard (3)
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (2)
251while (channel.Reader.TryRead(out var pendingSpan)) 306while (channel.Reader.TryRead(out var pendingLog))
src\Shared\ChannelExtensions.cs (1)
48while (!cancellationToken.IsCancellationRequested && channel.Reader.TryRead(out var log))
Aspire.Dashboard.Components.Tests (9)
Interactions\InteractionsProviderTests.cs (1)
130Assert.False(selectedRequestsChannel.Reader.TryRead(out _));
Interactions\InteractionsProviderTests.Terminal.cs (5)
79Assert.False(requests.Reader.TryRead(out _)); 127Assert.False(shown.Reader.TryRead(out _)); 143Assert.False(shown.Reader.TryRead(out _)); 151Assert.False(requests.Reader.TryRead(out _)); 152Assert.False(shown.Reader.TryRead(out _));
Layout\TerminalDockTelemetryTests.cs (1)
131while (fixture.LogChannel.Reader.TryRead(out var log))
Pages\ResourcesTests.cs (2)
61Assert.True(fixture.LogChannel.Reader.TryRead(out var initializeLog)); 78Assert.True(fixture.LogChannel.Reader.TryRead(out var log));
Aspire.Dashboard.Playwright.Tests (1)
Integration\Playwright\Infrastructure\TestTerminalConnectionResolver.cs (1)
43while (_connections.Reader.TryRead(out _))
Aspire.Dashboard.Tests (41)
Integration\StartupTests.cs (2)
1200Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 1266Assert.True(fixture.LogChannel.Reader.TryRead(out var log));
Model\DashboardClientTests.cs (1)
1402if (channel.TryRead(out var update))
Model\DashboardCommandExecutorTests.cs (1)
98Assert.True(fixture.ActivityChannel.Reader.TryRead(out var activity));
ResourceOutgoingPeerResolverTests.cs (1)
295Assert.False(resultChannel.Reader.TryRead(out _));
Telemetry\AspireTelemetryBaseTests.cs (2)
84Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 117Assert.True(fixture.LogChannel.Reader.TryRead(out var log));
Telemetry\ComponentTelemetryContextTests.cs (7)
24Assert.True(fixture.LogChannel.Reader.TryRead(out var initializeEvent)); 30Assert.True(fixture.LogChannel.Reader.TryRead(out var parametersUpdateEvent)); 38Assert.True(fixture.LogChannel.Reader.TryRead(out parametersUpdateEvent)); 43Assert.True(fixture.LogChannel.Reader.TryRead(out var disposeEvent)); 62Assert.False(fixture.LogChannel.Reader.TryRead(out _)); 87Assert.False(fixture.LogChannel.Reader.TryRead(out _)); 91Assert.False(fixture.LogChannel.Reader.TryRead(out _));
Telemetry\DashboardStartupTelemetryTests.cs (5)
46Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 87Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 112Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 138Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 171Assert.True(fixture.LogChannel.Reader.TryRead(out var log));
Telemetry\DashboardTelemetryLogExportTests.cs (2)
83Assert.True(exporter.LogChannel.Reader.TryRead(out var log)); 104Assert.True(exporter.LogChannel.Reader.TryRead(out var shutdownLog));
Telemetry\DashboardTelemetryManagerTests.cs (1)
49Assert.True(exporter.LogChannel.Reader.TryRead(out var log));
Telemetry\DashboardTelemetryMetadataTests.cs (3)
67Assert.True(fixture.LogChannel.Reader.TryRead(out var startup)); 73Assert.True(fixture.LogChannel.Reader.TryRead(out var usage)); 133Assert.True(fixture.LogChannel.Reader.TryRead(out var record));
Telemetry\DashboardTelemetryServiceTests.cs (13)
42Assert.True(fixture.ActivityChannel.Reader.TryRead(out var recorded)); 112Assert.True(fixture.LogChannel.Reader.TryRead(out var initializeEvent)); 113Assert.True(fixture.LogChannel.Reader.TryRead(out var parametersEvent)); 141Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 169Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 190Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 215Assert.True(fixture.LogChannel.Reader.TryRead(out var errorLog)); 228Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 236Assert.True(fixture.ActivityChannel.Reader.TryRead(out var recorded)); 256Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 287Assert.True(fixture.LogChannel.Reader.TryRead(out var errorLog)); 312Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 375Assert.True(fixture.LogChannel.Reader.TryRead(out var log));
Telemetry\TelemetryErrorRecorderTests.cs (1)
169while (fixture.LogChannel.Reader.TryRead(out var log))
Telemetry\TelemetryLoggerProviderTests.cs (2)
35Assert.True(fixture.LogChannel.Reader.TryRead(out var log)); 77Assert.True(fixture.LogChannel.Reader.TryRead(out var log));
Aspire.Hosting (4)
ApplicationModel\TerminalService.cs (2)
346channel.Reader.TryRead(out change); 445while (channel.Reader.TryRead(out var pending))
Devcontainers\DevcontainerSettingsWriter.cs (1)
76while (reader.TryRead(out var entry))
src\Shared\ChannelExtensions.cs (1)
48while (!cancellationToken.IsCancellationRequested && channel.Reader.TryRead(out var log))
Aspire.Hosting.Azure (1)
AzureProvisioningController.cs (1)
1559while (_operationChannel.Reader.TryRead(out var operation))
Aspire.Hosting.Azure.Tests (4)
AzureEnvironmentResourceExtensionsTests.cs (2)
3166Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 3777Assert.False(testInteractionService.Interactions.Reader.TryRead(out _));
ProvisioningContextProviderTests.cs (2)
53Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 84Assert.False(interactionService.Interactions.Reader.TryRead(out _));
Aspire.Hosting.Native.Core.AotSmoke (1)
tests\Aspire.Hosting.Native.Core.Tests\TestServices\DiagnosticCapture.cs (1)
65while (_subscription.Reader.TryRead(out var value))
Aspire.Hosting.Native.Core.Tests (1)
TestServices\DiagnosticCapture.cs (1)
65while (_subscription.Reader.TryRead(out var value))
Aspire.Hosting.Tests (80)
Backchannel\BackchannelLoggerProviderTests.cs (4)
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));
Dcp\DcpHostNotificationTests.cs (6)
208Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 253Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 848Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 885Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 983Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 1028Assert.False(interactionService.Interactions.Reader.TryRead(out _));
DotnetProgramPublishingTests.cs (2)
399Assert.False(interactions.Interactions.Reader.TryRead(out _)); 419Assert.False(interactions.Interactions.Reader.TryRead(out _));
Orchestrator\ParameterProcessorTests.cs (7)
141Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 160Assert.False(interactionService.Interactions.Reader.TryRead(out _)); 385Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 388Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 443Assert.False(interactions.Interactions.Reader.TryRead(out _)); 468Assert.False(interactions.Interactions.Reader.TryRead(out _)); 1918Assert.False(testInteractionService.Interactions.Reader.TryRead(out _));
Publishing\ContainerRuntimeReadinessTests.cs (4)
26Assert.False(interactions.Interactions.Reader.TryRead(out _)); 42Assert.False(interactions.Interactions.Reader.TryRead(out _)); 64Assert.False(interactions.Interactions.Reader.TryRead(out _)); 96Assert.False(interactions.Interactions.Reader.TryRead(out _));
Publishing\PipelineActivityReporterTests.cs (48)
42Assert.True(activityReader.TryRead(out var activity)); 67Assert.True(activityReader.TryRead(out var createActivity)); 73Assert.True(activityReader.TryRead(out var completeActivity)); 86reporter.ActivityItemUpdated.Reader.TryRead(out _); 95Assert.True(activityReader.TryRead(out var createActivity)); 112reporter.ActivityItemUpdated.Reader.TryRead(out _); 129Assert.True(activityReader.TryRead(out var activity)); 182reporter.ActivityItemUpdated.Reader.TryRead(out _); 194Assert.True(activityReader.TryRead(out var activity)); 214reporter.ActivityItemUpdated.Reader.TryRead(out _); 215reporter.ActivityItemUpdated.Reader.TryRead(out _); 227Assert.True(activityReader.TryRead(out var activity)); 286reporter.ActivityItemUpdated.Reader.TryRead(out _); 287reporter.ActivityItemUpdated.Reader.TryRead(out _); 300Assert.True(activityReader.TryRead(out var activity)); 343Assert.True(activityReader.TryRead(out var activity)); 364Assert.True(activityReader.TryRead(out var activity)); 397while (activityReader.TryRead(out _)) { } 403Assert.True(activityReader.TryRead(out var activity)); 567while (activityReader.TryRead(out _)) { } 772reporter.ActivityItemUpdated.Reader.TryRead(out _); 783Assert.True(activityReader.TryRead(out var activity)); 817Assert.True(activityReader.TryRead(out var activity)); 860reporter.ActivityItemUpdated.Reader.TryRead(out _); 861reporter.ActivityItemUpdated.Reader.TryRead(out _); 874Assert.True(activityReader.TryRead(out var activity)); 895reporter.ActivityItemUpdated.Reader.TryRead(out _); 896reporter.ActivityItemUpdated.Reader.TryRead(out _); 909Assert.True(activityReader.TryRead(out var activity)); 933Assert.True(activityReader.TryRead(out var activity)); 954Assert.True(activityReader.TryRead(out var activity)); 980Assert.True(activityReader.TryRead(out var activity)); 1007Assert.True(activityReader.TryRead(out var activity)); 1030Assert.True(activityReader.TryRead(out var activity)); 1043reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 1055Assert.True(activityReader.TryRead(out var activity)); 1072reporter.ActivityItemUpdated.Reader.TryRead(out _); 1080Assert.True(activityReader.TryRead(out var activity)); 1123reporter.ActivityItemUpdated.Reader.TryRead(out _); 1124reporter.ActivityItemUpdated.Reader.TryRead(out _); 1135Assert.True(activityReader.TryRead(out var activity)); 1146reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 1154Assert.True(activityReader.TryRead(out var activity)); 1174Assert.True(activityReader.TryRead(out var activity)); 1194Assert.True(activityReader.TryRead(out var activity)); 1213Assert.True(activityReader.TryRead(out var activity)); 1380while (reporter.ActivityItemUpdated.Reader.TryRead(out _)) { } 1385Assert.False(reporter.ActivityItemUpdated.Reader.TryRead(out _));
RequiredCommandAnnotationTests.cs (2)
434Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 467Assert.False(testInteractionService.Interactions.Reader.TryRead(out _));
ResourceCommandServiceTests.cs (1)
1530Assert.False(testInteractionService.Interactions.Reader.TryRead(out _));
Terminals\TerminalServiceTests.cs (1)
153Assert.False(channel.Reader.TryRead(out _));
VersionChecking\VersionCheckServiceTests.cs (5)
101Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 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 _));
Aspire.Hosting.TestUtilities (2)
Utils\Grpc\TestAsyncStreamReader.cs (1)
40_channel.Reader.TryRead(out var message))
Utils\Grpc\TestServerStreamWriter.cs (1)
39_channel.Reader.TryRead(out var message);
Aspire.TerminalHost (1)
DcpUpstreamAdapter.cs (1)
123if (!_outputChannel.Reader.TryRead(out var first))
GenerateDocumentationAndConfigFiles (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
34while (reader.TryRead(out var item))
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http2\Http2FrameWriter.cs (1)
182while (_channel.Reader.TryRead(out var producer) && !producer.CompletedResponse)
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)
Internal\NamedPipeConnectionListener.cs (1)
151if (_acceptedQueue.Reader.TryRead(out var connection))
Microsoft.AspNetCore.SignalR.Client.Core (8)
HubConnection.cs (3)
974while (reader.TryRead(out var item)) 1204while (!tokenSource.Token.IsCancellationRequested && reader.TryRead(out var item)) 1935while (invocationMessageChannelReader.TryRead(out var invocationMessage))
HubConnectionExtensions.StreamAsChannelAsync.cs (1)
293while (inputChannel.TryRead(out var item))
src\aspnetcore\src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (2)
46if (_channel.TryRead(out var item)) 59if (_channel.TryRead(out var item))
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (2)
161if (_waitForAck.Reader.TryRead(out var count) && count < _bufferLimit) 170_waitForAck.Reader.TryRead(out _);
Microsoft.AspNetCore.SignalR.Core (5)
Internal\ChannelBasedSemaphore.cs (1)
26return _channel.Reader.TryRead(out _);
src\aspnetcore\src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (2)
46if (_channel.TryRead(out var item)) 59if (_channel.TryRead(out var item))
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (2)
161if (_waitForAck.Reader.TryRead(out var count) && count < _bufferLimit) 170_waitForAck.Reader.TryRead(out _);
Microsoft.CodeAnalysis.Analyzers (2)
src\roslyn\src\Dependencies\Threading\ChannelReaderExtensions.cs (1)
24while (reader.TryRead(out var item))
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
34while (reader.TryRead(out var item))
Microsoft.CodeAnalysis.AnalyzerUtilities (2)
src\roslyn\src\Dependencies\Threading\ChannelReaderExtensions.cs (1)
24while (reader.TryRead(out var item))
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
34while (reader.TryRead(out var item))
Microsoft.CodeAnalysis.CodeStyle (2)
src\roslyn\src\Dependencies\Threading\ChannelReaderExtensions.cs (1)
24while (reader.TryRead(out var item))
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
34while (reader.TryRead(out var item))
Microsoft.CodeAnalysis.ResxSourceGenerator (2)
src\roslyn\src\Dependencies\Threading\ChannelReaderExtensions.cs (1)
24while (reader.TryRead(out var item))
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
34while (reader.TryRead(out var item))
Microsoft.CodeAnalysis.Workspaces (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
34while (reader.TryRead(out var item))
Microsoft.ML.Data (1)
Transforms\RowShufflingTransformer.cs (1)
574if (!_toProduceChannel.Reader.TryRead(out requested))
Roslyn.Diagnostics.Analyzers (2)
src\roslyn\src\Dependencies\Threading\ChannelReaderExtensions.cs (1)
24while (reader.TryRead(out var item))
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
34while (reader.TryRead(out var item))
System.Diagnostics.Process (1)
System\Diagnostics\Process.Multiplexing.cs (1)
553while (channel.Reader.TryRead(out ProcessOutputLine line))
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
1233while (_writeChannel.Reader.TryRead(out WriteQueueEntry? writeEntry))
System.Net.Quic (2)
System\Net\Quic\QuicConnection.cs (1)
867while (_acceptQueue.Reader.TryRead(out QuicStream? stream))
System\Net\Quic\QuicListener.cs (1)
433while (_acceptQueue.Reader.TryRead(out object? item))
System.Threading.Channels (3)
System\Threading\Channels\ChannelReader.cs (3)
67if (TryRead(out T? fastItem)) 88if (TryRead(out T? item)) 107while (TryRead(out T? item))