1 write to RequestBodyPipe
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http3\Http3Stream.cs (1)
136
RequestBodyPipe
= CreateRequestBodyPipe(64 * 1024); // windowSize?
14 references to RequestBodyPipe
Microsoft.AspNetCore.Server.Kestrel.Core (14)
Internal\Http3\Http3MessageBody.cs (7)
46
_context.
RequestBodyPipe
.Reader.AdvanceTo(consumed, examined);
55
var hasResult = _context.
RequestBodyPipe
.Reader.TryRead(out readResult);
79
var readAwaitable = _context.
RequestBodyPipe
.Reader.ReadAsync(cancellationToken);
101
_context.
RequestBodyPipe
.Reader.Complete();
107
return _context.
RequestBodyPipe
.Reader.CompleteAsync();
112
_context.
RequestBodyPipe
.Reader.CancelPendingRead();
122
_context.
RequestBodyPipe
.Reader.Complete();
Internal\Http3\Http3Stream.cs (7)
142
RequestBodyPipe
.Reset();
196
RequestBodyPipe
.Writer.Complete(exception);
569
RequestBodyPipe
.Writer.Complete();
575
RequestBodyPipe
.Reader.Complete();
770
return
RequestBodyPipe
.Writer.CompleteAsync();
950
RequestBodyPipe
.Writer.Write(segment.Span);
953
return
RequestBodyPipe
.Writer.FlushAsync().GetAsTask();