ReadAsync

Internal\Http\HttpRequestPipeReader.cs (1)

59public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)

src\aspnetcore\src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)

52public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)

System\IO\Pipelines\Pipe.DefaultPipeReader.cs (1)

24public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) => _pipe.ReadAsync(cancellationToken);

System\IO\Pipelines\SequencePipeReader.cs (1)

62public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)

System\IO\Pipelines\StreamPipeReader.cs (1)

203public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)

Otlp\Http\OtlpHttpEndpointsBuilder.cs (1)

259result = await httpContext.Request.BodyReader.ReadAsync().ConfigureAwait(false);

Dcp\DcpHost.cs (1)

402var result = await reader.ReadAsync(CancellationToken.None).ConfigureAwait(false);

Internal\Transports\LongPollingServerTransport.cs (1)

36var result = await _application.ReadAsync(token);

Internal\Transports\ServerSentEventsServerTransport.cs (1)

51var result = await _application.ReadAsync(cancellationToken);

Internal\Transports\WebSocketsServerTransport.cs (1)

208var result = await _application.Input.ReadAsync();

Internal\SendUtils.cs (1)

27var result = await application.Input.ReadAsync(cancellationToken).ConfigureAwait(false);

Internal\WebSocketsTransport.cs (1)

540var result = await _application.Input.ReadAsync().ConfigureAwait(false);

Core\IISHttpContext.IO.cs (2)

30var result = await _bodyInputPipe!.Reader.ReadAsync(cancellationToken); 163var result = await _bodyOutput.Reader.ReadAsync();

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

121var result = await _input.ReadAsync(cancellationToken);

Internal\Http\Http1ChunkedEncodingMessageBody.cs (3)

68var readAwaitable = _requestBodyPipe.Reader.ReadAsync(cancellationToken); 100var awaitable = _context.Input.ReadAsync(); 152awaitable = _context.Input.ReadAsync();

Internal\Http\Http1Connection.cs (1)

848awaitable = Input.ReadAsync();

Internal\Http\Http1ContentLengthMessageBody.cs (1)

59var readAwaitable = _context.Input.ReadAsync(cancellationToken);

Internal\Http\Http1UpgradeMessageBody.cs (2)

80var readTask = _context.Input.ReadAsync(cancellationToken); 101readResult = await _context.Input.ReadAsync(cancellationToken);

Internal\Http2\Http2Connection.cs (3)

324var result = await Input.ReadAsync(); 557var result = await Input.ReadAsync(); 1897var readResult = await reader.ReadAsync();

Internal\Http2\Http2MessageBody.cs (1)

111var readAwaitable = _context.RequestBodyPipe.Reader.ReadAsync(cancellationToken);

Internal\Http3\Http3ControlStream.cs (2)

160var result = await Input.ReadAsync(); 263var result = await Input.ReadAsync();

Internal\Http3\Http3MessageBody.cs (1)

79var readAwaitable = _context.RequestBodyPipe.Reader.ReadAsync(cancellationToken);

Internal\Http3\Http3OutputProducer.cs (1)

419readResult = await _pipeReader.ReadAsync();

Internal\Http3\Http3PendingStream.cs (1)

50var result = await Input.ReadAsync();

Internal\Http3\Http3Stream.cs (1)

643var result = await Input.ReadAsync();

Middleware\TlsListener.cs (1)

33var result = await input.ReadAsync(cancellationToken);

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

121var result = await _input.ReadAsync(cancellationToken);

Internal\QuicStreamContext.cs (1)

383var result = await output.ReadAsync();

src\aspnetcore\src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)

54return _inner.ReadAsync(cancellationToken);

HubConnection.cs (2)

1520var result = await input.ReadAsync(linkedToken).ConfigureAwait(false); 1640var result = await input.ReadAsync().ConfigureAwait(false);

HubConnectionContext.cs (1)

547var result = await input.ReadAsync();

HubConnectionHandler.cs (1)

273var result = await input.ReadAsync();

src\aspnetcore\src\SignalR\common\testassets\Tests.Utils\TestClient.cs (1)

248var result = await Connection.Application.Input.ReadAsync();

ResponseBodyReaderStream.cs (1)

87var result = await _pipe.Reader.ReadAsync(cancellationToken);

FormPipeReader.cs (1)

96var readResult = await _pipeReader.ReadAsync(cancellationToken);

System\IO\Pipelines\PipeReader.cs (6)

System\IO\Pipelines\PipeReaderStream.cs (2)

66ValueTask<ReadResult> vt = _pipeReader.ReadAsync(); 107ReadResult result = await _pipeReader.ReadAsync(cancellationToken).ConfigureAwait(false);

System\IO\Pipelines\PipeWriter.cs (1)

56/// <summary>Makes bytes written available to <see cref="System.IO.Pipelines.PipeReader" /> and runs <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> continuation.</summary>

System\IO\Pipelines\ReadResult.cs (6)