4 overrides of ReadAsync
System.Threading.Channels (4)
System\Threading\Channels\BoundedChannel.cs (1)
137public override ValueTask<T> ReadAsync(CancellationToken cancellationToken)
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)
70public override ValueTask<T> ReadAsync(CancellationToken cancellationToken)
System\Threading\Channels\UnboundedChannel.cs (1)
63public override ValueTask<T> ReadAsync(CancellationToken cancellationToken)
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
69public override ValueTask<T> ReadAsync(CancellationToken cancellationToken)
53 references to ReadAsync
Aspire.Dashboard.Tests (8)
ChannelExtensionsTests.cs (4)
91var read1 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 96var read2 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 135var read1 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 140var read2Task = resultChannel.Reader.ReadAsync().DefaultTimeout();
ResourceOutgoingPeerResolverTests.cs (2)
142readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 149readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout();
TelemetryRepositoryTests\LogTests.cs (2)
749var read1 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 770var read2 = await resultChannel.Reader.ReadAsync().DefaultTimeout();
Aspire.Hosting.Tests (5)
Dashboard\DashboardLifecycleHookTests.cs (1)
68var logContext = await logChannel.Reader.ReadAsync().DefaultTimeout();
Dcp\TestKubernetesService.cs (1)
121var (evtType, res) = await chan.Reader.ReadAsync(cancellationToken);
Health\ResourceHealthCheckServiceTests.cs (3)
161var firstCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout(); 164var secondCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout(); 167var thirdCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout();
InMemory.FunctionalTests (5)
Http3\Http3ConnectionTests.cs (1)
385var maxFieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout();
Http3\Http3StreamTests.cs (1)
2799var maxFieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout();
Http3\WebTransport\WebTransportHandshakeTests.cs (2)
62await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 128await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout();
Http3\WebTransport\WebTransportTestUtilities.cs (1)
59await inMemory.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout();
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\WebTransport\WebTransportSession.cs (1)
175return await _pendingStreams.Reader.ReadAsync(cancellationToken);
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (8)
HubConnectionTests.cs (6)
803Assert.Equal("1", await channel.ReadAsync().AsTask().DefaultTimeout()); 805Assert.Equal("2", await channel.ReadAsync().AsTask().DefaultTimeout()); 850Assert.Equal("A", await channel.ReadAsync().AsTask().DefaultTimeout()); 851Assert.Equal("B", await channel.ReadAsync().AsTask().DefaultTimeout()); 852Assert.Equal("C", await channel.ReadAsync().AsTask().DefaultTimeout()); 853Assert.Equal("D", await channel.ReadAsync().AsTask().DefaultTimeout());
HubConnectionTests.Tracing.cs (2)
83clientActivity1 = await clientChannel.Reader.ReadAsync().DefaultTimeout(); 105clientActivity2 = await clientChannel.Reader.ReadAsync().DefaultTimeout();
Microsoft.AspNetCore.SignalR.Core (1)
Internal\ChannelBasedSemaphore.cs (1)
32return _channel.Reader.ReadAsync(cancellationToken);
Microsoft.AspNetCore.SignalR.Tests (20)
HubConnectionHandlerTests.Activity.cs (17)
54var connectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 63var invocation1Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 69var invocation2Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 75var invocation3Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 78var userCodeActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 87var disconnectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 129var connectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 145var invocationActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 159var disconnectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 200var connectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 205var invocation1Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 210var invocation2Activity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 218var disconnectedActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 259var connectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 271var invocationActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 285var disconnectActivity = await serverChannel.Reader.ReadAsync().DefaultTimeout(); 330var activity = await serverChannel.Reader.ReadAsync().DefaultTimeout();
HubConnectionHandlerTestUtils\Hubs.cs (3)
917var result = _channel.ReadAsync(_cancellationToken); 1380total += await channelReader.ReadAsync(); 1404await channelReader.ReadAsync();
Microsoft.Extensions.ServiceDiscovery.Tests (1)
ServiceEndpointResolverTests.cs (1)
273var next = await channel.Reader.ReadAsync(CancellationToken.None);
Microsoft.ML.Data (1)
Transforms\RowShufflingTransformer.cs (1)
637ValueTask<int> readTask = _toConsumeChannel.Reader.ReadAsync();
Microsoft.ML.Sweeper (1)
AsyncSweeper.cs (1)
282return await _paramChannel.Reader.ReadAsync(_cts.Token);
System.Net.Quic (2)
System\Net\Quic\QuicConnection.cs (1)
577return await _acceptQueue.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);
System\Net\Quic\QuicListener.cs (1)
183object item = await _acceptQueue.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);