TryRead

6 overrides of TryRead

Microsoft.AspNetCore.SignalR.Tests (1)

HubConnectionHandlerTestUtils\Hubs.cs (1)

880public override bool TryRead(out T item)

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)

99 references to TryRead

Aspire.Confluent.Kafka (1)

MetricsService.cs (1)

21while (channel.Reader.TryRead(out var json))

Aspire.Dashboard (3)

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.Tests (10)

ResourceOutgoingPeerResolverTests.cs (1)

136Assert.False(resultChannel.Reader.TryRead(out readValue));

Telemetry\ComponentTelemetryContextTests.cs (9)

Aspire.Hosting (1)

src\Shared\ChannelExtensions.cs (1)

48while (!cancellationToken.IsCancellationRequested && channel.Reader.TryRead(out var log))

Aspire.Hosting.Tests (5)

Utils\Grpc\TestAsyncStreamReader.cs (1)

40_channel.Reader.TryRead(out var message))

Utils\Grpc\TestServerStreamWriter.cs (1)

37_channel.Reader.TryRead(out var message);

VersionChecking\VersionCheckServiceTests.cs (3)

96Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 157Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 186Assert.False(interactionService.Interactions.Reader.TryRead(out var _));

ClientSample (2)

StreamingSample.cs (1)

37while (reader.TryRead(out var item))

UploadSample.cs (1)

99while (outputs.TryRead(out var item))

GenerateDocumentationAndConfigFiles (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))

InMemory.FunctionalTests (3)

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

117while (reader.TryRead(out var stream)) 1060while (ToServerAcceptQueue.Reader.TryRead(out var connection))

TestTransport\InMemoryTransportFactory.cs (1)

28while (_acceptQueue.Reader.TryRead(out var item))

Metrics (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))

Metrics.Legacy (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))

Microsoft.AspNetCore.Http.Connections.Tests (3)

TestWebSocketConnectionFeature.cs (3)

138if (_input.TryRead(out var message)) 214if (_input.TryRead(out var message)) 235while (_input.TryRead(out var message))

Microsoft.AspNetCore.Server.Kestrel.Core (1)

Internal\Http2\Http2FrameWriter.cs (1)

182while (_channel.Reader.TryRead(out var producer) && !producer.CompletedResponse)

Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (2)

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

117while (reader.TryRead(out var stream)) 1060while (ToServerAcceptQueue.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)

688while (reader.TryRead(out var item)) 943while (!tokenSource.Token.IsCancellationRequested && reader.TryRead(out var item)) 1620while (invocationMessageChannelReader.TryRead(out var invocationMessage))

HubConnectionExtensions.StreamAsChannelAsync.cs (1)

293while (inputChannel.TryRead(out var item))

src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (2)

46if (_channel.TryRead(out var item)) 59if (_channel.TryRead(out var item))

src\SignalR\common\Shared\MessageBuffer.cs (2)

141if (_waitForAck.Reader.TryRead(out var count) && count < _bufferLimit) 150_waitForAck.Reader.TryRead(out _);

Microsoft.AspNetCore.SignalR.Client.FunctionalTests (4)

HubConnectionTests.cs (2)

900while (channel.TryRead(out var item)) 2960while (_taskQueue.Reader.TryRead(out var tuple))

Hubs.cs (2)

259while (source.TryRead(out var item)) 283while (source.TryRead(out var item))

Microsoft.AspNetCore.SignalR.Core (5)

Internal\ChannelBasedSemaphore.cs (1)

26return _channel.Reader.TryRead(out _);

src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (2)

46if (_channel.TryRead(out var item)) 59if (_channel.TryRead(out var item))

src\SignalR\common\Shared\MessageBuffer.cs (2)

141if (_waitForAck.Reader.TryRead(out var count) && count < _bufferLimit) 150_waitForAck.Reader.TryRead(out _);

Microsoft.AspNetCore.SignalR.Microbenchmarks (1)

DefaultHubDispatcherBenchmark.cs (1)

198while (channelReader.TryRead(out var item))

Microsoft.AspNetCore.SignalR.Tests (6)

HubConnectionHandlerTestUtils\Hubs.cs (6)

197while (source.TryRead(out var item)) 218while (source.TryRead(out var item)) 232while (source.TryRead(out var item)) 248while (source.TryRead(out var item)) 315while (source.TryRead(out var item)) 820while (source.TryRead(out string item))

Microsoft.AspNetCore.SignalR.Tests.Utils (2)

ChannelExtensions.cs (2)

17while (channel.TryRead(out var item)) 48while (reader.TryRead(out var item))

Microsoft.CodeAnalysis.Analyzers (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))

Microsoft.CodeAnalysis.AnalyzerUtilities (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))

Microsoft.CodeAnalysis.BannedApiAnalyzers (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))

Microsoft.CodeAnalysis.CodeStyle (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))

Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))

Microsoft.CodeAnalysis.PublicApiAnalyzers (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))

Microsoft.CodeAnalysis.ResxSourceGenerator (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))

Microsoft.CodeAnalysis.Workspaces (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))

Microsoft.Extensions.AI (1)

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

172while (channel.TryRead(out var update))

Microsoft.ML.Data (1)

Transforms\RowShufflingTransformer.cs (1)

574if (!_toProduceChannel.Reader.TryRead(out requested))

Roslyn.Diagnostics.Analyzers (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))

SignalR.Client.FunctionalTestApp (1)

TestHub.cs (1)

89while (stream.TryRead(out var item))

SignalRSamples (3)

Hubs\UploadHub.cs (3)

26while (source.TryRead(out var item)) 52while (reader.TryRead(out var item)) 71while (source.TryRead(out var item))

System.Net.Http (1)

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

1212while (_writeChannel.Reader.TryRead(out WriteQueueEntry? writeEntry))

System.Net.Quic (2)

System\Net\Quic\QuicConnection.cs (1)

863while (_acceptQueue.Reader.TryRead(out QuicStream? stream))

System\Net\Quic\QuicListener.cs (1)

431while (_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))

Test.Utilities (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))

TestDiscoveryWorker (1)

Program.cs (1)

125while (_channel.Reader.TryRead(out var item))

Text.Analyzers (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

86while (reader.TryRead(out var item))

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)

51while (reader.TryRead(out var item))