TryRead

5 overrides of TryRead

Microsoft.AspNetCore.SignalR.Tests (1)

HubConnectionHandlerTestUtils\Hubs.cs (1)

880public override bool TryRead(out T item)

System.Threading.Channels (4)

System\Threading\Channels\BoundedChannel.cs (1)

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

113public override bool TryRead([MaybeNullWhen(false)] out T item)

System\Threading\Channels\UnboundedPriorityChannel.cs (1)

113public override bool TryRead([MaybeNullWhen(false)] out T item)

57 references to TryRead

Aspire.Dashboard (1)

src\Shared\ChannelExtensions.cs (1)

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

Aspire.Dashboard.Tests (1)

ResourceOutgoingPeerResolverTests.cs (1)

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

Aspire.Hosting (1)

src\Shared\ChannelExtensions.cs (1)

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

ClientSample (2)

StreamingSample.cs (1)

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

UploadSample.cs (1)

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

InMemory.FunctionalTests (3)

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

118while (reader.TryRead(out var stream)) 1057while (ToServerAcceptQueue.Reader.TryRead(out var connection))

TestTransport\InMemoryTransportFactory.cs (1)

28while (_acceptQueue.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)

118while (reader.TryRead(out var stream)) 1057while (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)

682while (reader.TryRead(out var item)) 937while (!tokenSource.Token.IsCancellationRequested && reader.TryRead(out var item)) 1610while (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)

140if (_waitForAck.Reader.TryRead(out var count) && count < _bufferLimit) 149_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)

140if (_waitForAck.Reader.TryRead(out var count) && count < _bufferLimit) 149_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.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.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.ML.Data (1)

Transforms\RowShufflingTransformer.cs (1)

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

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)

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

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

TestDiscoveryWorker (1)

Program.cs (1)

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