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_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.