aioduct 0.2.0-alpha.7

Async-native HTTP client built directly on hyper 1.x — no hyper-util, no legacy
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

use bytes::Bytes;
use http::header::HeaderMap;
use http::{Method, Uri, Version};
use http_body_util::BodyExt;

use crate::body::RequestBodySend;

pub(super) fn retry_request_from_parts(
    method: Method,
    uri: Uri,
    version: Version,
    headers: HeaderMap,
    replay_body: &Option<Bytes>,
) -> http::Request<RequestBodySend> {
    let retry_body_bytes = replay_body.as_ref().cloned().unwrap_or_else(Bytes::new);
    let body: RequestBodySend = http_body_util::Full::new(retry_body_bytes)
        .map_err(|never| match never {})
        .boxed_unsync();
    let mut retry_req = http::Request::new(body);
    *retry_req.method_mut() = method;
    *retry_req.uri_mut() = uri;
    *retry_req.headers_mut() = headers;
    // Strip user-supplied framing headers to prevent smuggling.
    retry_req
        .headers_mut()
        .remove(http::header::TRANSFER_ENCODING);
    retry_req.headers_mut().remove(http::header::CONTENT_LENGTH);
    *retry_req.version_mut() = version;
    retry_req
}