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:

```rust use axum::{Router, routing::get}; use hyper::server::conn::http1; use std::net::SocketAddr; use tokio::net::TcpListener; use towerhttp::trace::TraceLayer; use towerhyperhttpbody_compat::TowerService03HttpServiceAsHyper1HttpService;

[tokio::main]

async fn main() -> Result<(), Box> { let app = Router::new() .route("/", get(|| async { "Hello, World!" })) // we can still add regular tower middleware .layer(TraceLayer::newforhttp());

// `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);
        }
    });
}

} ```