Struct StreamingResponseBody 

pub struct StreamingResponseBody<'scope> { /* private fields */ }

Pull input backed by the connection’s HTTP reader, with no response frame queue. The boxed stream retains the decoder’s borrowed state across reads. Dropping a pending read retains that state; cancelling an active read retires the exchange. Return/drop active handles before joining cancelled cleanup.

Trait Implementations

impl ReadableBody for StreamingResponseBody<'_>

type Data = Vec<u8>

Application data, without imposing completion-I/O buffer requirements.

type Error = Error

fn length(&self) -> Option<u64>

Total representation length, independent of the current read position.

fn may_have_trailers(&self) -> bool

Whether this body can emit trailing headers. HTTP/1 needs this before reading to choose chunked framing, even when the data length is known. Returning false promises that no Headers frame will be produced.

fn is_empty(&self) -> bool

Whether no unread payload frames remain. False can mean unknown; an open queue with no frames is not exhausted. This does not suppress read errors.

fn close(&mut self, _: Option<Error>)

Abandon further application reads, optionally reporting their failure.

async fn read( &mut self, cancellation: &Cancellation, ) -> Result<BodyFrame<Vec<u8>>, Error>

Read one owned frame. Pre-cancellation prevents consumption. The caller stops after frame.is_end(); subsequent reads return BodyFrame::End. Headers occur at most once, after all data. Dropping a pending read is not transport retirement, and must not lose an unreturned queued frame.

fn is_ready(&self) -> bool

Whether another read can proceed without waiting for produced data.

fn is_rewindable(&self) -> bool

fn rewind(&mut self) -> bool

Restore the read position when supported, reporting success.