aioduct 0.2.4

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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

#![cfg(feature = "tokio")]

//! Integration tests targeting dispatch_send.rs code paths for coverage.

#[path = "dispatch/basic_features.rs"]
mod basic_features;
#[path = "dispatch/connection_pool.rs"]
mod connection_pool;
#[path = "dispatch/dispatch_misc.rs"]
mod dispatch_misc;
#[path = "dispatch/forward_etc.rs"]
mod forward_etc;
#[path = "dispatch/tcp_h2c.rs"]
mod tcp_h2c;

use basic_features::TestObserver;

use std::convert::Infallible;
use std::sync::Arc;
use std::sync::Mutex;
use std::sync::atomic::{AtomicU32, Ordering};
use std::time::Duration;

use bytes::Bytes;
use http_body_util::Full;
use hyper::{Request, Response};

use aioduct::HttpEngineSend;
use aioduct::observer::{ConnectionEvent, RequestEvent, RequestObserver, RequestPhase};
use aioduct::runtime::TokioRuntime;
use aioduct::runtime::tokio_rt::TcpConnector;

use aioduct_test_server::h1::{echo, h1_server, h1_server_with};
use aioduct_test_server::h2::h2_server_with;

fn valid_forward_request<B>(mut request: Request<B>) -> Request<B> {
    if request.version() == http::Version::HTTP_11
        && !request.headers().contains_key(http::header::HOST)
    {
        request.headers_mut().insert(
            http::header::HOST,
            http::HeaderValue::from_static("downstream.test"),
        );
    }
    request
}