ReadAsync

5 overrides of ReadAsync

System.Threading.Channels (5)

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

147public override ValueTask<T> ReadAsync(CancellationToken cancellationToken)

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

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

68public override ValueTask<T> ReadAsync(CancellationToken cancellationToken)

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

75public override ValueTask<T> ReadAsync(CancellationToken cancellationToken)

68 references to ReadAsync

Aspire.Dashboard.Components.Tests (3)

Pages\ConsoleLogsTests.cs (2)

94var subscribedResourceName1 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout(); 120var subscribedResourceName2 = await subscribedResourceNamesChannel.Reader.ReadAsync().DefaultTimeout();

Shared\TestDashboardClient.cs (1)

48return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask();

Aspire.Dashboard.Tests (11)

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

Integration\DashboardClientAuthTests.cs (2)

45var call = await server.Calls.ApplicationInformationCallsChannel.Reader.ReadAsync().DefaultTimeout(); 61var call = await server.Calls.ApplicationInformationCallsChannel.Reader.ReadAsync().DefaultTimeout();

ResourceOutgoingPeerResolverTests.cs (3)

144readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 152readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 160readValue = await resultChannel.Reader.ReadAsync().DefaultTimeout();

TelemetryRepositoryTests\LogTests.cs (2)

748var read1 = await resultChannel.Reader.ReadAsync().DefaultTimeout(); 769var read2 = await resultChannel.Reader.ReadAsync().DefaultTimeout();

Aspire.Hosting (1)

Backchannel\AppHostRpcTarget.cs (1)

30var publishingActivityStatus = await activityReporter.ActivityStatusUpdated.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);

Aspire.Hosting.Tests (9)

Dashboard\DashboardLifecycleHookTests.cs (1)

69var logContext = await logChannel.Reader.ReadAsync().DefaultTimeout();

Dcp\TestKubernetesService.cs (1)

149var (evtType, res) = await chan.Reader.ReadAsync(cancellationToken);

DistributedApplicationTests.cs (2)

638await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout(); 648await beforeResourceStartedEvents.Reader.ReadAsync().DefaultTimeout();

Health\ResourceHealthCheckServiceTests.cs (5)

172var e1 = await channel.Reader.ReadAsync().DefaultTimeout(); 200var e2 = await channel.Reader.ReadAsync().DefaultTimeout(); 320var firstCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout(); 323var secondCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout(); 326var thirdCheck = await channel.Reader.ReadAsync(abortTokenSource.Token).DefaultTimeout();

InMemory.FunctionalTests (8)

Http3\Http3ConnectionTests.cs (1)

414var maxFieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout();

Http3\Http3StreamTests.cs (4)

2816var maxFieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 3246var fieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 3251fieldSetting = await Http3Api.ServerReceivedSettingsReader.ReadAsync().DefaultTimeout(); 3255fieldSetting = 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)

HubConnectionHandlerTestUtils\Hubs.cs (3)

917var result = _channel.ReadAsync(_cancellationToken); 1380total += await channelReader.ReadAsync(); 1409await 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)

574return await _acceptQueue.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);

System\Net\Quic\QuicListener.cs (1)

183object item = await _acceptQueue.Reader.ReadAsync(cancellationToken).ConfigureAwait(false);

System.Threading.Channels (1)

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

556/// <summary>Represents a blocked reader from <see cref="ChannelReader{T}.ReadAsync"/>.</summary>