1 write to _bodyInputPipe
Microsoft.AspNetCore.Server.IIS (1)
Core\IISHttpContext.cs (1)
493_bodyInputPipe = new Pipe(new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.ThreadPool, minimumSegmentSize: MinAllocBufferSize));
8 references to _bodyInputPipe
Microsoft.AspNetCore.Server.IIS (8)
Core\IISHttpContext.IO.cs (7)
30var result = await _bodyInputPipe!.Reader.ReadAsync(cancellationToken); 48_bodyInputPipe.Reader.AdvanceTo(readableBuffer.End, readableBuffer.End); 60return _bodyInputPipe!.Reader.CopyToAsync(destination, cancellationToken); 103var memory = _bodyInputPipe!.Writer.GetMemory(); 117_bodyInputPipe.Writer.Advance(read); 125var result = await _bodyInputPipe.Writer.FlushAsync(); 151_bodyInputPipe!.Writer.Complete(error);
Core\IISHttpContextOfT.cs (1)
101_bodyInputPipe?.Reader.Complete();