1 write to RequestBodyPipe
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http2\Http2Stream.cs (1)
77RequestBodyPipe = CreateRequestBodyPipe();
14 references to RequestBodyPipe
Microsoft.AspNetCore.Server.Kestrel.Core (14)
Internal\Http2\Http2MessageBody.cs (7)
71_context.RequestBodyPipe.Reader.AdvanceTo(consumed, examined); 87var hasResult = _context.RequestBodyPipe.Reader.TryRead(out readResult); 111var readAwaitable = _context.RequestBodyPipe.Reader.ReadAsync(cancellationToken); 133_context.RequestBodyPipe.Reader.Complete(); 139return _context.RequestBodyPipe.Reader.CompleteAsync(); 144_context.RequestBodyPipe.Reader.CancelPendingRead(); 154_context.RequestBodyPipe.Reader.Complete();
Internal\Http2\Http2Stream.cs (7)
85RequestBodyPipe.Reset(); 173RequestBodyPipe.Writer.Complete(); 179RequestBodyPipe.Reader.Complete(); 504dataPayload.CopyTo(RequestBodyPipe.Writer); 510var flushTask = RequestBodyPipe.Writer.FlushAsync(); 545RequestBodyPipe.Writer.Complete(); 624RequestBodyPipe.Writer.Complete(abortReason);