1 write to _requestBodyPipe
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)
34_requestBodyPipe = CreateRequestBodyPipe(context);
10 references to _requestBodyPipe
Microsoft.AspNetCore.Server.Kestrel.Core (10)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (10)
40_requestBodyPipe.Reader.AdvanceTo(consumed, examined); 47var boolResult = _requestBodyPipe.Reader.TryRead(out _readResult); 66var readAwaitable = _requestBodyPipe.Reader.ReadAsync(cancellationToken); 87_requestBodyPipe.Reader.CancelPendingRead(); 128done = Read(readableBuffer, _requestBodyPipe.Writer, out consumed, out examined); 130await _requestBodyPipe.Writer.FlushAsync(); 159await _requestBodyPipe.Writer.CompleteAsync(error); 171_requestBodyPipe.Reader.Complete(); 179_requestBodyPipe.Reset(); 194_requestBodyPipe.Reset();