1 write to _requestBodyPipe
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)
36_requestBodyPipe = CreateRequestBodyPipe(context);
10 references to _requestBodyPipe
Microsoft.AspNetCore.Server.Kestrel.Core (10)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (10)
42_requestBodyPipe.Reader.AdvanceTo(consumed, examined); 49var boolResult = _requestBodyPipe.Reader.TryRead(out _readResult); 68var readAwaitable = _requestBodyPipe.Reader.ReadAsync(cancellationToken); 89_requestBodyPipe.Reader.CancelPendingRead(); 130done = Read(readableBuffer, _requestBodyPipe.Writer, out consumed, out examined); 132await _requestBodyPipe.Writer.FlushAsync(); 161await _requestBodyPipe.Writer.CompleteAsync(error); 173_requestBodyPipe.Reader.Complete(); 181_requestBodyPipe.Reset(); 196_requestBodyPipe.Reset();