Struct RequestReader 

pub struct RequestReader<R> { /* private fields */ }

Sequential request admission. Input read-ahead survives body completion and protocol switches. Failed reads and dropped head reads prohibit further admission; a dropped or cancelled body read loses no input.

Implementations

impl<R: ReadableStream> RequestReader<R>

pub fn new(reader: R, options: Options) -> Result<Self, Error>

pub fn is_poisoned(&self) -> bool

Whether a started head read failed or was dropped, a body read failed other than by cancellation, or the input was closed. The input position is then unknown and the input cannot be reused. A dropped or cancelled body read, or a body left unread, does not poison input, so after a request is admitted this reports a failed read, usually of a malformed or truncated request.

pub fn is_reusable(&self) -> bool

pub async fn read_request( &mut self, cancellation: &Cancellation, ) -> Result<Option<(Request<IncomingBody<'_, R>>, Exchange)>, Error>

Clean EOF between requests returns None; partial heads are errors.

pub async fn close(&mut self) -> Result<()>

Establish backend retirement even after cancellation or parse failure.