#hyper-http #hyper #tower-http #axum #tower #hyper-server

tower-hyper-http-body-compat

Adapters between hyper 0.14-1.0, http-body 0.4-1.0, and tower-service 0.3

6 releases

0.2.0 Jul 15, 2023
0.1.4 Mar 21, 2023
0.1.2 Feb 26, 2023

#5 in #tower-http

Download history 105/week @ 2024-03-14 82/week @ 2024-03-21 103/week @ 2024-03-28 117/week @ 2024-04-04 227/week @ 2024-04-11 75/week @ 2024-04-18 101/week @ 2024-04-25 80/week @ 2024-05-02 94/week @ 2024-05-09 72/week @ 2024-05-16 70/week @ 2024-05-23 98/week @ 2024-05-30 84/week @ 2024-06-06 79/week @ 2024-06-13 55/week @ 2024-06-20 37/week @ 2024-06-27

278 downloads per month

MIT/Apache

32KB
535 lines

tower-hyper-http-body-compat

tower-hyper-http-body-compat provides adapters between hyper 0.14-1.0, http-body 0.4-1.0, and tower-service 0.3.

Build status Crates.io Documentation

More information about this crate can be found in the crate documentation.

Example

Running an axum Router with hyper 1.0:

use axum::{Router, routing::get};
use hyper::server::conn::http1;
use std::net::SocketAddr;
use tokio::net::TcpListener;
use tower_http::trace::TraceLayer;
use tower_hyper_http_body_compat::TowerService03HttpServiceAsHyper1HttpService;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    let app = Router::new()
        .route("/", get(|| async { "Hello, World!" }))
         // we can still add regular tower middleware
         .layer(TraceLayer::new_for_http());

    // `Router` implements tower-service 0.3's `Service` trait. Convert that to something
    // that implements hyper 1.0's `Service` trait.
    let service = TowerService03HttpServiceAsHyper1HttpService::new(app);

    let addr: SocketAddr = ([127, 0, 0, 1], 8080).into();

    let mut tcp_listener = TcpListener::bind(addr).await?;
    loop {
        let (tcp_stream, _) = tcp_listener.accept().await?;

        // hyper-util isn't on crates.io yet. Instead depend on it via git
        // `hyper-util = { git = "https://github.com/hyperium/hyper-util" }`
        let tcp_stream = hyper_util::rt::TokioIo::new(tcp_stream);

        let service = service.clone();
        tokio::task::spawn(async move {
            if let Err(http_err) = http1::Builder::new()
                    .keep_alive(true)
                    .serve_connection(tcp_stream, service)
                    .await {
                eprintln!("Error while serving HTTP connection: {}", http_err);
            }
        });
    }
}

Dependencies

~4.5–6.5MB
~116K SLoC