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