WaitToReadAsync

5 overrides of WaitToReadAsync

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)

41 references to WaitToReadAsync

aspire (1)

Interaction\ExtensionInteractionService.cs (1)

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

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)

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

Aspire.Dashboard.Tests (4)

Integration\McpServiceTests.cs (2)

283while (await testTelemetrySender.ContextChannel.Reader.WaitToReadAsync().DefaultTimeout()) 296while (await testTelemetrySender.ContextChannel.Reader.WaitToReadAsync().DefaultTimeout())

Model\AIAssistant\AIContextProviderTests.cs (1)

115Assert.False(await changeChannel.Reader.WaitToReadAsync().DefaultTimeout());

ResourceOutgoingPeerResolverTests.cs (1)

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

Aspire.Hosting (2)

Devcontainers\DevcontainerSettingsWriter.cs (1)

72while (await reader.WaitToReadAsync(_processingCancellation.Token).ConfigureAwait(false))

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

GenerateDocumentationAndConfigFiles (1)

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

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

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

Internal\Http2\Http2FrameWriter.cs (1)

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

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\aspnetcore\src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (1)

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

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

146while (await _waitForAck.Reader.WaitToReadAsync(linkedToken).ConfigureAwait(false))

Microsoft.AspNetCore.SignalR.Core (2)

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

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

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

146while (await _waitForAck.Reader.WaitToReadAsync(linkedToken).ConfigureAwait(false))

Microsoft.CodeAnalysis.Analyzers (2)

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

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

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

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

Microsoft.CodeAnalysis.AnalyzerUtilities (2)

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

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

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

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

Microsoft.CodeAnalysis.CodeStyle (2)

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

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

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

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

Microsoft.CodeAnalysis.ResxSourceGenerator (2)

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

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

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

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

Microsoft.CodeAnalysis.Workspaces (1)

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

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

Microsoft.Extensions.AI (1)

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

168while (await channel.WaitToReadAsync(cancellationToken))

Microsoft.ML.Data (1)

Transforms\RowShufflingTransformer.cs (1)

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

Roslyn.Diagnostics.Analyzers (2)

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

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

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

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

System.Diagnostics.Process (1)

System\Diagnostics\Process.Multiplexing.cs (1)

551while (await channel.Reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false))

System.Net.Http (1)

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

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

System.Threading.Channels (3)

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

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