TryRead

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)

MetricsService.cs (1)

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

Otlp\Storage\TelemetryRepository.Watchers.cs (2)

89while (channel.Reader.TryRead(out var pendingSpan)) 175while (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 _))

ResourceOutgoingPeerResolverTests.cs (1)

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

Telemetry\ComponentTelemetryContextTests.cs (9)

Devcontainers\DevcontainerSettingsWriter.cs (1)

76while (reader.TryRead(out var entry))

src\Shared\ChannelExtensions.cs (1)

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

Backchannel\BackchannelLoggerProviderTests.cs (4)

97Assert.True(channel1.Reader.TryRead(out var entry1a)); 99Assert.True(channel1.Reader.TryRead(out var entry1b)); 102Assert.True(channel2.Reader.TryRead(out var entry2a)); 104Assert.True(channel2.Reader.TryRead(out var entry2b));

Publishing\PipelineActivityReporterTests.cs (44)

RequiredCommandAnnotationTests.cs (2)

402Assert.False(testInteractionService.Interactions.Reader.TryRead(out _)); 435Assert.False(testInteractionService.Interactions.Reader.TryRead(out _));

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 (4)

102Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 183Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 218Assert.False(interactionService.Interactions.Reader.TryRead(out var _)); 247Assert.False(interactionService.Interactions.Reader.TryRead(out var _));

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

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

Internal\Http2\Http2FrameWriter.cs (1)

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

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\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 _);

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 _);

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))

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))

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))

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))

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

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

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

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

Transforms\RowShufflingTransformer.cs (1)

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

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.Multiplexing.cs (1)

553while (channel.Reader.TryRead(out ProcessOutputLine line))

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

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

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\ChannelReader.cs (3)

67if (TryRead(out T? fastItem)) 88if (TryRead(out T? item)) 107while (TryRead(out T? item))