Struct CgiResponseBody 

pub struct CgiResponseBody<R, G = ()> { /* private fields */ }

Streaming body for a CGI response: yields the leftover bytes (from the post-header read) first, then reads the rest from the child’s stdout to EOF. A total_deadline caps the total streaming time; mid-body the next poll_frame past the deadline returns an io::Error.

G is a generic drop guard that the body owns for its lifetime — typically a permit, an Arc, or a cancellation guard the host wants to keep alive while bytes are still flowing. Use () when you don’t need one.

Implementations

impl<R, G> CgiResponseBody<R, G>

pub fn new(initial: Vec<u8>, stdout: R, deadline: Instant, guard: G) -> Self

Build a body from a leftover-bytes prefix, an open reader, the wall-clock deadline for stream completion, and a caller-supplied drop guard.

Trait Implementations

impl<R, G> Body for CgiResponseBody<R, G>

where R: AsyncRead + Unpin + Send, G: Send + Unpin + 'static,

type Data = Bytes

Values yielded by the Body.

type Error = Error

The error type this Body might generate.

fn poll_frame( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>>

Attempt to pull out the next data buffer of this stream.

fn is_end_stream(&self) -> bool

Returns true when the end of stream has been reached.

fn size_hint(&self) -> SizeHint

Returns the bounds on the remaining length of the stream.