Struct ResumableResponse 

pub struct ResumableResponse { /* private fields */ }

A wrapper for reqwest::Response to allow for resumable byte streams

Implementations

impl ResumableResponse

pub fn response(self) -> Response

Get the underlying reqwest::Response

pub fn bytes_stream_resumable( self, ) -> impl Stream<Item = Result<Bytes, Error>> + Send + Unpin

Convert the response into a Stream of Bytes from the body.

Example

use futures_util::StreamExt;
use reqwest_partial_retry::ClientExt;

let client = reqwest::Client::new().resumable();
let request = client.get("http://httpbin.org/ip").build().unwrap();
let mut stream = client
    .execute_resumable(request)
    .await?
    .bytes_stream_resumable();

while let Some(item) = stream.next().await {
    println!("Bytes: {:?}", item?);
}

Methods from Deref<Target = Response>

pub fn status(&self) -> StatusCode

Get the StatusCode of this Response.

pub fn version(&self) -> Version

Get the HTTP Version of this Response.

pub fn headers(&self) -> &HeaderMap

Get the Headers of this Response.

pub fn content_length(&self) -> Option<u64>

Get the content-length of this response, if known.

Reasons it may not be known:

• The server didn’t send a content-length header.
• The response is compressed and automatically decoded (thus changing the actual decoded length).

pub fn url(&self) -> &Url

Get the final Url of this Response.

pub fn remote_addr(&self) -> Option<SocketAddr>

Get the remote address used to get this Response.

pub fn extensions(&self) -> &Extensions

Returns a reference to the associated extensions.

pub fn error_for_status_ref(&self) -> Result<&Response, Error>

Turn a reference to a response into an error if the server returned an error.

Example

fn on_response(res: &Response) {
    match res.error_for_status_ref() {
        Ok(_res) => (),
        Err(err) => {
            // asserting a 400 as an example
            // it could be any status between 400...599
            assert_eq!(
                err.status(),
                Some(reqwest::StatusCode::BAD_REQUEST)
            );
        }
    }
}

Trait Implementations

impl Deref for ResumableResponse

type Target = Response

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.