Struct StreamResponse 

pub struct StreamResponse {
    pub url: Url,
    pub status: StatusCode,
    pub headers: HeaderMap,
    pub body_stream: Pin<Box<dyn Stream<Item = Result<Bytes, Error>> + Send>>,
    pub request_url: Url,
    pub meta: DashMap<Cow<'static, str>, Value>,
    pub cached: bool,
}

A stream response that allows processing of large responses without loading the entire body into memory at once.

Fields

url: Url

The final URL of the response after any redirects.

status: StatusCode

The HTTP status code of the response.

headers: HeaderMap

The headers of the response.

body_stream: Pin<Box<dyn Stream<Item = Result<Bytes, Error>> + Send>>

The body of the response as a stream of Bytes chunks.

request_url: Url

The original URL of the request that led to this response.

meta: DashMap<Cow<'static, str>, Value>

Metadata associated with the response, carried over from the request.

cached: bool

Indicates if the response was served from a cache.

Implementations

impl StreamResponse

pub async fn to_response(self) -> Result<Response, Error>

Converts the stream response to a regular response by collecting all body chunks. This defeats the purpose of streaming but provides compatibility with existing code.

pub async fn into_html(self) -> Result<Html, Error>

Provides a way to parse the stream response as HTML by collecting chunks until enough data is available for parsing. Note: This consumes the stream response to collect all data.

pub async fn into_links(self) -> Result<Vec<Link>, Error>

Extracts links from the stream response by consuming and parsing the content. Note: This consumes the stream response to collect all data.

Trait Implementations

impl Debug for StreamResponse

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.