WaitToReadAsync

6 overrides of WaitToReadAsync

Microsoft.AspNetCore.SignalR.Tests (1)

HubConnectionHandlerTestUtils\Hubs.cs (1)

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

System.Threading.Channels (5)

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

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

System\Threading\Channels\RendezvousChannel.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)

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

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

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

95 references to WaitToReadAsync

aspire (1)

Interaction\ExtensionInteractionService.cs (1)

35while (await _extensionTaskChannel.Reader.WaitToReadAsync().ConfigureAwait(false))

Aspire.Cli.Tests (7)

Hosting\CliOrphanDetectorTests.cs (7)

49Assert.True(await stopSignalChannel.Reader.WaitToReadAsync()); 76Assert.True(await processRunningChannel.Reader.WaitToReadAsync()); 79Assert.True(await processRunningChannel.Reader.WaitToReadAsync()); 82Assert.True(await processRunningChannel.Reader.WaitToReadAsync()); 85Assert.True(await processRunningChannel.Reader.WaitToReadAsync()); 88Assert.True(await processRunningChannel.Reader.WaitToReadAsync()); 91Assert.True(await stopSignalChannel.Reader.WaitToReadAsync());

Aspire.Confluent.Kafka (1)

MetricsService.cs (1)

19while (await channel.Reader.WaitToReadAsync(stoppingToken).ConfigureAwait(false))

Aspire.Dashboard (2)

src\Shared\ChannelExtensions.cs (1)

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

Telemetry\DashboardTelemetrySender.cs (1)

51while (await _channel.Reader.WaitToReadAsync().ConfigureAwait(false))

Aspire.Dashboard.Components.Tests (1)

Pages\ConsoleLogsTests.cs (1)

173Assert.False(await subscribedResourceNamesChannel.Reader.WaitToReadAsync().DefaultTimeout());

Aspire.Dashboard.Tests (1)

ResourceOutgoingPeerResolverTests.cs (1)

173Assert.False(await resultChannel.Reader.WaitToReadAsync().DefaultTimeout());

Aspire.Hosting (1)

src\Shared\ChannelExtensions.cs (1)

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

Aspire.Hosting.Tests (2)

Utils\Grpc\TestAsyncStreamReader.cs (1)

39if (await _channel.Reader.WaitToReadAsync(cancellationToken) &&

Utils\Grpc\TestServerStreamWriter.cs (1)

35if (await _channel.Reader.WaitToReadAsync())

ClientSample (2)

StreamingSample.cs (1)

35while (await reader.WaitToReadAsync())

UploadSample.cs (1)

97while (await outputs.WaitToReadAsync())

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

InMemory.FunctionalTests (3)

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

112while (await reader.WaitToReadAsync().DefaultTimeout()) 1058while (await ToServerAcceptQueue.Reader.WaitToReadAsync(cancellationToken))

TestTransport\InMemoryTransportFactory.cs (1)

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

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

Metrics.Legacy (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.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)

114while (await reader.WaitToReadAsync()) 1058while (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)

686while (await reader.WaitToReadAsync(cts.Token).ConfigureAwait(false)) 941while (await reader.WaitToReadAsync(tokenSource.Token).ConfigureAwait(false)) 1618while (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)

139while (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)

139while (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.Analyzers (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.AnalyzerUtilities (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.BannedApiAnalyzers (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.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.PerformanceSensitiveAnalyzers (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.PublicApiAnalyzers (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.ResxSourceGenerator (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.Extensions.AI (1)

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

170while (await channel.WaitToReadAsync(cancellationToken))

Microsoft.ML.Data (1)

Transforms\RowShufflingTransformer.cs (1)

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

Roslyn.Diagnostics.Analyzers (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))

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.Threading.Channels (3)

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

581/// <summary>Represents a waiting reader from <see cref="ChannelReader{T}.WaitToReadAsync"/>.</summary>

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

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

Test.Utilities (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))

TestDiscoveryWorker (1)

Program.cs (1)

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

Text.Analyzers (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))