RequestBodyPipe

1 write to RequestBodyPipe

Microsoft.AspNetCore.Server.Kestrel.Core (1)

Internal\Http3\Http3Stream.cs (1)

144RequestBodyPipe = 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); 55var hasResult = _context.RequestBodyPipe.Reader.TryRead(out readResult); 79var readAwaitable = _context.RequestBodyPipe.Reader.ReadAsync(cancellationToken); 101_context.RequestBodyPipe.Reader.Complete(); 107return _context.RequestBodyPipe.Reader.CompleteAsync(); 112_context.RequestBodyPipe.Reader.CancelPendingRead(); 122_context.RequestBodyPipe.Reader.Complete();

Internal\Http3\Http3Stream.cs (7)

150RequestBodyPipe.Reset(); 204RequestBodyPipe.Writer.Complete(exception); 583RequestBodyPipe.Writer.Complete(); 589RequestBodyPipe.Reader.Complete(); 784return RequestBodyPipe.Writer.CompleteAsync(); 966RequestBodyPipe.Writer.Write(segment.Span); 969return RequestBodyPipe.Writer.FlushAsync().GetAsTask();