WaitToReadAsync

5 overrides of WaitToReadAsync

Microsoft.AspNetCore.SignalR.Tests (1)

HubConnectionHandlerTestUtils\Hubs.cs (1)

886public override ValueTask<bool> WaitToReadAsync(CancellationToken cancellationToken = default)

System.Threading.Channels (4)

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

187public override ValueTask<bool> WaitToReadAsync(CancellationToken cancellationToken)

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

140public override ValueTask<bool> WaitToReadAsync(CancellationToken cancellationToken)

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

140public override ValueTask<bool> WaitToReadAsync(CancellationToken cancellationToken)

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

150public override ValueTask<bool> WaitToReadAsync(CancellationToken cancellationToken)

56 references to WaitToReadAsync

Aspire.Dashboard (1)

src\Shared\ChannelExtensions.cs (1)

36if (await channel.Reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false))

Aspire.Hosting (1)

src\Shared\ChannelExtensions.cs (1)

36if (await channel.Reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false))

ClientSample (2)

StreamingSample.cs (1)

35while (await reader.WaitToReadAsync())

UploadSample.cs (1)

97while (await outputs.WaitToReadAsync())

InMemory.FunctionalTests (3)

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

113while (await reader.WaitToReadAsync().DefaultTimeout()) 1055while (await ToServerAcceptQueue.Reader.WaitToReadAsync(cancellationToken))

TestTransport\InMemoryTransportFactory.cs (1)

26if (await _acceptQueue.Reader.WaitToReadAsync(cancellationToken))

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

TestWebSocketConnectionFeature.cs (3)

136await _input.WaitToReadAsync(cancellationToken); 212while (await _input.WaitToReadAsync()) 233while (await _input.WaitToReadAsync())

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

Internal\Http2\Http2FrameWriter.cs (1)

178while (await _channel.Reader.WaitToReadAsync())

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

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

115while (await reader.WaitToReadAsync()) 1055while (await ToServerAcceptQueue.Reader.WaitToReadAsync(cancellationToken))

Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)

Internal\NamedPipeConnectionListener.cs (1)

149while (await _acceptedQueue.Reader.WaitToReadAsync(cancellationToken))

Microsoft.AspNetCore.SignalR.Client.Core (6)

HubConnection.cs (3)

680while (await reader.WaitToReadAsync(cts.Token).ConfigureAwait(false)) 935while (await reader.WaitToReadAsync(tokenSource.Token).ConfigureAwait(false)) 1608while (await invocationMessageChannelReader.WaitToReadAsync().ConfigureAwait(false))

HubConnectionExtensions.StreamAsChannelAsync.cs (1)

291while (await inputChannel.WaitToReadAsync().ConfigureAwait(false))

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

57while (await _channel.WaitToReadAsync(_cancellationToken).ConfigureAwait(false))

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

138while (await _waitForAck.Reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false))

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

HubConnectionTests.cs (3)

898while (await channel.WaitToReadAsync()) 982await channel.WaitToReadAsync().AsTask().DefaultTimeout(); 2957while (await _taskQueue.Reader.WaitToReadAsync())

Hubs.cs (2)

257while (await source.WaitToReadAsync()) 281while (await source.WaitToReadAsync())

Microsoft.AspNetCore.SignalR.Core (2)

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

57while (await _channel.WaitToReadAsync(_cancellationToken).ConfigureAwait(false))

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

138while (await _waitForAck.Reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false))

Microsoft.AspNetCore.SignalR.Microbenchmarks (1)

DefaultHubDispatcherBenchmark.cs (1)

196while (await channelReader.WaitToReadAsync())

Microsoft.AspNetCore.SignalR.Tests (13)

HubConnectionHandlerTestUtils\Hubs.cs (13)

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

ChannelExtensions.cs (2)

15while (await channel.WaitToReadAsync()) 59var readTask = reader.WaitToReadAsync(cancellationToken).AsTask();

Microsoft.CodeAnalysis.CodeStyle (2)

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

84while (await reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false))

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

47while (await reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false))

Microsoft.CodeAnalysis.Workspaces (2)

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

84while (await reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false))

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

47while (await reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false))

Microsoft.ML.Data (1)

Transforms\RowShufflingTransformer.cs (1)

571while (await _toProduceChannel.Reader.WaitToReadAsync().ConfigureAwait(false))

SignalR.Client.FunctionalTestApp (1)

TestHub.cs (1)

87while (await stream.WaitToReadAsync())

SignalRSamples (3)

Hubs\UploadHub.cs (3)

24while (await source.WaitToReadAsync()) 50while (await reader.WaitToReadAsync()) 69while (await source.WaitToReadAsync())

System.Net.Http (1)

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

1197while (await _writeChannel.Reader.WaitToReadAsync().ConfigureAwait(false))

System.Threading.Channels (2)

System\Threading\Channels\ChannelReader.cs (2)

83if (!await WaitToReadAsync(ct).ConfigureAwait(false)) 105while (await WaitToReadAsync(cancellationToken).ConfigureAwait(false))

TestDiscoveryWorker (1)

Program.cs (1)

120while (await _channel.Reader.WaitToReadAsync(CancellationToken.None).ConfigureAwait(false))