Struct StreamingResponse 

#[non_exhaustive]
pub struct StreamingResponse {
    pub url: Url,
    pub status: StatusCode,
    pub headers: HeaderMap,
    pub body: BoxStream<'static, Result<Bytes, HttpClientError>>,
}

An HTTP response whose body arrives as a byte stream.

Examples

use futures_util::stream;
use http::{HeaderMap, StatusCode};
use millipede_core::http_client::StreamingResponse;
use url::Url;

let response = StreamingResponse::new(
    Url::parse("https://example.com/")?,
    StatusCode::OK,
    HeaderMap::new(),
    Box::pin(stream::empty()),
);
assert_eq!(response.status, StatusCode::OK);

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

url: Url

Final URL after redirects.

status: StatusCode

HTTP response status.

headers: HeaderMap

HTTP response headers.

body: BoxStream<'static, Result<Bytes, HttpClientError>>

Stream of response body chunks.

Implementations

impl StreamingResponse

pub fn new( url: Url, status: StatusCode, headers: HeaderMap, body: BoxStream<'static, Result<Bytes, HttpClientError>>, ) -> Self

Creates a streaming response.

Trait Implementations

impl Debug for StreamingResponse

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

Formats the value using the given formatter.