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)
126 references to TryRead
aspire (1)
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 (5)
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (2)
252while (channel.Reader.TryRead(out var pendingSpan)) 307while (channel.Reader.TryRead(out var pendingLog))
src\Shared\ChannelExtensions.cs (1)
48while (!cancellationToken.IsCancellationRequested && channel.Reader.TryRead(out var log))
Telemetry\DashboardTelemetrySender.cs (2)
53while (_channel.Reader.TryRead(out var operation)) 107while (_channel.Reader.TryRead(out _))
Aspire.Dashboard.Components.Tests (1)
Interactions\InteractionsProviderTests.cs (1)
129Assert.False(selectedRequestsChannel.Reader.TryRead(out _));
Aspire.Dashboard.Tests (10)
ResourceOutgoingPeerResolverTests.cs (1)
295Assert.False(resultChannel.Reader.TryRead(out _));
Telemetry\ComponentTelemetryContextTests.cs (9)
29Assert.True(telemetrySender.ContextChannel.Reader.TryRead(out var postPropertyOperation)); 33Assert.True(telemetrySender.ContextChannel.Reader.TryRead(out var initializeOperation)); 44Assert.True(telemetrySender.ContextChannel.Reader.TryRead(out parametersUpdateOperation)); 51Assert.False(telemetrySender.ContextChannel.Reader.TryRead(out parametersUpdateOperation)); 55Assert.True(telemetrySender.ContextChannel.Reader.TryRead(out parametersUpdateOperation)); 59Assert.True(telemetrySender.ContextChannel.Reader.TryRead(out var disposeOperation)); 77Assert.False(telemetrySender.ContextChannel.Reader.TryRead(out _)); 102Assert.False(telemetrySender.ContextChannel.Reader.TryRead(out _)); 106Assert.False(telemetrySender.ContextChannel.Reader.TryRead(out _));
Aspire.Hosting (2)
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)
1514while (_operationChannel.Reader.TryRead(out var operation))
Aspire.Hosting.Azure.Tests (2)
AzureEnvironmentResourceExtensionsTests.cs (2)
2848Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 3459Assert.False(testInteractionService.Interactions.Reader.TryRead(out _));
Aspire.Hosting.Tests (61)
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));
Orchestrator\ParameterProcessorTests.cs (1)
308Assert.False(testInteractionService.Interactions.Reader.TryRead(out _));
Publishing\PipelineActivityReporterTests.cs (48)
44Assert.True(activityReader.TryRead(out var activity)); 69Assert.True(activityReader.TryRead(out var createActivity)); 75Assert.True(activityReader.TryRead(out var completeActivity)); 88reporter.ActivityItemUpdated.Reader.TryRead(out _); 97Assert.True(activityReader.TryRead(out var createActivity)); 114reporter.ActivityItemUpdated.Reader.TryRead(out _); 131Assert.True(activityReader.TryRead(out var activity)); 184reporter.ActivityItemUpdated.Reader.TryRead(out _); 196Assert.True(activityReader.TryRead(out var activity)); 216reporter.ActivityItemUpdated.Reader.TryRead(out _); 217reporter.ActivityItemUpdated.Reader.TryRead(out _); 229Assert.True(activityReader.TryRead(out var activity)); 288reporter.ActivityItemUpdated.Reader.TryRead(out _); 289reporter.ActivityItemUpdated.Reader.TryRead(out _); 302Assert.True(activityReader.TryRead(out var activity)); 345Assert.True(activityReader.TryRead(out var activity)); 366Assert.True(activityReader.TryRead(out var activity)); 399while (activityReader.TryRead(out _)) { } 405Assert.True(activityReader.TryRead(out var activity)); 569while (activityReader.TryRead(out _)) { } 774reporter.ActivityItemUpdated.Reader.TryRead(out _); 785Assert.True(activityReader.TryRead(out var activity)); 819Assert.True(activityReader.TryRead(out var activity)); 862reporter.ActivityItemUpdated.Reader.TryRead(out _); 863reporter.ActivityItemUpdated.Reader.TryRead(out _); 876Assert.True(activityReader.TryRead(out var activity)); 897reporter.ActivityItemUpdated.Reader.TryRead(out _); 898reporter.ActivityItemUpdated.Reader.TryRead(out _); 911Assert.True(activityReader.TryRead(out var activity)); 935Assert.True(activityReader.TryRead(out var activity)); 956Assert.True(activityReader.TryRead(out var activity)); 982Assert.True(activityReader.TryRead(out var activity)); 1009Assert.True(activityReader.TryRead(out var activity)); 1032Assert.True(activityReader.TryRead(out var activity)); 1045reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 1057Assert.True(activityReader.TryRead(out var activity)); 1074reporter.ActivityItemUpdated.Reader.TryRead(out _); 1082Assert.True(activityReader.TryRead(out var activity)); 1125reporter.ActivityItemUpdated.Reader.TryRead(out _); 1126reporter.ActivityItemUpdated.Reader.TryRead(out _); 1137Assert.True(activityReader.TryRead(out var activity)); 1148reporter.ActivityItemUpdated.Reader.TryRead(out _); // Clear step activity 1156Assert.True(activityReader.TryRead(out var activity)); 1176Assert.True(activityReader.TryRead(out var activity)); 1196Assert.True(activityReader.TryRead(out var activity)); 1215Assert.True(activityReader.TryRead(out var activity)); 1382while (reporter.ActivityItemUpdated.Reader.TryRead(out _)) { } 1387Assert.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)
1427Assert.False(testInteractionService.Interactions.Reader.TryRead(out _));
VersionChecking\VersionCheckServiceTests.cs (5)
103Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 184Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 219Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 248Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 285Assert.False(interactionService.Interactions.Reader.TryRead(out var _));
Aspire.Hosting.TestUtilities (2)
Utils\Grpc\TestAsyncStreamReader.cs (1)
40_channel.Reader.TryRead(out var message))
Utils\Grpc\TestServerStreamWriter.cs (1)
37_channel.Reader.TryRead(out var message);
Aspire.TerminalHost (1)
DcpUpstreamAdapter.cs (1)
118if (!_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.DirectTls (2)
Connection\DirectTlsConnectionListener.cs (2)
167if (_readyConnections.Reader.TryRead(out var connection)) 195while (_readyConnections.Reader.TryRead(out var connection))
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)) 1928while (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)
148if (_waitForAck.Reader.TryRead(out var count) && count < _bufferLimit) 157_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)
148if (_waitForAck.Reader.TryRead(out var count) && count < _bufferLimit) 157_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.Extensions.AI (1)
ChatCompletion\AnonymousDelegatingChatClient.cs (1)
170while (channel.TryRead(out var update))
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)
864while (_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))