ReadResult

Internal\Http\Http1ContentLengthMessageBody.cs (5)

39return new ReadResult(_readResult.Buffer, Interlocked.Exchange(ref _userCanceled, 0) == 1, isCompleted: true); 126readResult = new ReadResult(_readResult.Buffer, Interlocked.Exchange(ref _userCanceled, 0) == 1, isCompleted: true); 196_readResult = new ReadResult( 221_readResult = new ReadResult(new ReadOnlySequence<byte>(), isCanceled: false, isCompleted: true); 230_readResult = new ReadResult(buffer, isCanceled: false, isCompleted: true);

Internal\Http\ZeroContentLengthMessageBody.cs (2)

18public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) => new ValueTask<ReadResult>(new ReadResult(default, isCanceled: false, isCompleted: true)); 28result = new ReadResult(default, isCanceled: false, isCompleted: true);

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

974result = new ReadResult(readOnlySequence, isCanceled, isCompleted); 978result = new ReadResult(default, isCanceled, isCompleted);

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

69result = new ReadResult(ReadOnlySequence<byte>.Empty, isCanceled: false, isCompleted: true); 81result = new ReadResult(_sequence, isCancellationRequested, isCompleted: true);

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

302return new ReadResult(reader.GetCurrentReadOnlySequence(), isCanceled, isCompleted); 474result = new ReadResult(buffer, isCancellationRequested, false);

Otlp\Http\OtlpHttpEndpointsBuilder.cs (2)

254ReadResult result = default; 288if (!result.Equals(default(ReadResult)))

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\Http\Http1ChunkedEncodingMessageBody.cs (4)

29private ReadResult _readResult; 45public override bool TryReadInternal(out ReadResult readResult) 62public override async ValueTask<ReadResult> ReadAsyncInternal(CancellationToken cancellationToken = default) 109var result = await awaitable;

Internal\Http\Http1Connection.cs (2)

846protected override bool BeginRead(out ValueTask<ReadResult> awaitable) 852protected override bool TryParseRequest(ReadResult result, out bool endConnection)

Internal\Http\Http1ContentLengthMessageBody.cs (3)

15private ReadResult _readResult; 32public override async ValueTask<ReadResult> ReadAsyncInternal(CancellationToken cancellationToken = default) 119public override bool TryReadInternal(out ReadResult readResult)

Internal\Http\Http1MessageBody.cs (6)

29public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) 35public abstract ValueTask<ReadResult> ReadAsyncInternal(CancellationToken cancellationToken = default); 37public override bool TryRead(out ReadResult readResult) 43public abstract bool TryReadInternal(out ReadResult readResult); 55while (TryReadInternal(out var readResult)) 92ReadResult result;

Internal\Http\Http1UpgradeMessageBody.cs (9)

26public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) 32public override bool TryRead(out ReadResult result) 59public override bool TryReadInternal(out ReadResult readResult) 73public override ValueTask<ReadResult> ReadAsyncInternal(CancellationToken cancellationToken = default) 75ReadResult readResult; 90return new ValueTask<ReadResult>(readResult); 94private async ValueTask<ReadResult> ReadAsyncInternalAwaited(ValueTask<ReadResult> readTask, CancellationToken cancellationToken = default) 96var readResult = await readTask;

Internal\Http\HttpProtocol.cs (4)

472protected virtual bool BeginRead(out ValueTask<ReadResult> awaitable) 482protected abstract bool TryParseRequest(ReadResult result, out bool endConnection); 665var result = default(ReadResult);

Internal\Http\HttpRequestPipeReader.cs (2)

59public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) 66public override bool TryRead(out ReadResult result)

Internal\Http\HttpRequestStream.cs (1)

118var result = await _pipeReader.ReadAsync(cancellationToken);

Internal\Http\MessageBody.cs (7)

48public abstract ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default); 50public abstract bool TryRead(out ReadResult readResult); 203protected ValueTask<ReadResult> StartTimingReadAsync(ValueTask<ReadResult> readAwaitable, CancellationToken cancellationToken) 227protected async ValueTask<ReadResult> StartTimingReadAwaited(ValueTask<FlushResult> continueTask, ValueTask<ReadResult> readAwaitable, CancellationToken cancellationToken) 261protected long TrackConsumedAndExaminedBytes(ReadResult readResult, SequencePosition consumed, SequencePosition examined)

Internal\Http\ZeroContentLengthMessageBody.cs (3)

18public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) => new ValueTask<ReadResult>(new ReadResult(default, isCanceled: false, isCompleted: true)); 26public override bool TryRead(out ReadResult result)

Internal\Http2\Http2Connection.cs (3)

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

Internal\Http2\Http2FrameWriter.cs (1)

192reader.TryRead(out var readResult);

Internal\Http2\Http2MessageBody.cs (3)

24private ReadResult _readResult; 83public override bool TryRead(out ReadResult readResult) 105public override async ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)

Internal\Http2\Http2Stream.cs (1)

213protected override bool TryParseRequest(ReadResult result, out bool endConnection)

Internal\Http3\Http3ControlStream.cs (2)

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

Internal\Http3\Http3MessageBody.cs (3)

15private ReadResult _readResult; 51public override bool TryRead(out ReadResult readResult) 73public override async ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)

Internal\Http3\Http3OutputProducer.cs (1)

415ReadResult readResult;

Internal\Http3\Http3PendingStream.cs (1)

50var result = await Input.ReadAsync();

Internal\Http3\Http3Stream.cs (2)

643var result = await Input.ReadAsync(); 1017protected override bool TryParseRequest(ReadResult result, out bool endConnection)

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

52public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) 57public override bool TryRead(out ReadResult result)

HubConnectionContext.cs (1)

547var result = await input.ReadAsync();

HubConnectionHandler.cs (1)

273var result = await input.ReadAsync();

FormPipeReader.cs (1)

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

System\IO\Pipelines\Pipe.cs (18)

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

13private sealed class DefaultPipeReader : PipeReader, IValueTaskSource<ReadResult> 22public override bool TryRead(out ReadResult result) => _pipe.TryRead(out result); 24public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) => _pipe.ReadAsync(cancellationToken); 26protected override ValueTask<ReadResult> ReadAtLeastAsyncCore(int minimumBytes, CancellationToken cancellationToken) => _pipe.ReadAtLeastAsync(minimumBytes, cancellationToken); 42public ReadResult GetResult(short token) => _pipe.GetReadAsyncResult();

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

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

66ValueTask<ReadResult> vt = _pipeReader.ReadAsync(); 67ReadResult result = vt.IsCompletedSuccessfully ? vt.Result : vt.AsTask().GetAwaiter().GetResult(); 107ReadResult result = await _pipeReader.ReadAsync(cancellationToken).ConfigureAwait(false); 111private int HandleReadResult(ReadResult result, Span<byte> buffer)

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

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

62public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) 64if (TryRead(out ReadResult result)) 66return new ValueTask<ReadResult>(result); 70return new ValueTask<ReadResult>(result); 74public override bool TryRead(out ReadResult result)

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

203public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) 208protected override ValueTask<ReadResult> ReadAtLeastAsyncCore(int minimumSize, CancellationToken cancellationToken) 213private ValueTask<ReadResult> ReadInternalAsync(int? minimumSize, CancellationToken cancellationToken) 220return new ValueTask<ReadResult>(Task.FromCanceled<ReadResult>(cancellationToken)); 225if (TryReadInternal(tokenSource, out ReadResult readResult)) 232return new ValueTask<ReadResult>(readResult); 241static async ValueTask<ReadResult> Core(StreamPipeReader reader, int? minimumSize, CancellationTokenSource tokenSource, CancellationToken cancellationToken) 455public override bool TryRead(out ReadResult result) 462private bool TryReadInternal(CancellationTokenSource source, out ReadResult result)

System\Text\Json\Serialization\PipeReadBufferState.cs (1)

62ReadResult readResult = await _utf8Json.ReadAtLeastAsync(minBufferSize, cancellationToken).ConfigureAwait(false);