vibeio-http 0.4.0

High-performance HTTP server primitives for the `vibeio` runtime
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

#[cfg(feature = "h2")]
mod server {
    use bytes::Bytes;
    use http::{Response, StatusCode};
    use http_body_util::Full;
    use vibeio::net::TcpListener;
    use vibeio::RuntimeBuilder;
    use vibeio_http::{Http2, Http2Options, HttpProtocol};

    // h2spec conformance server. Listen on 127.0.0.1:8080 and answer every
    // request with a 200 response carrying a small non-empty body. Run via
    // `scripts/h2spec.sh`, which starts this binary, waits for readiness, runs
    // h2spec with `--strict`, and propagates its exit code.
    pub fn main() -> std::io::Result<()> {
        // In production, multiple vibeio threads would be used...
        let runtime = RuntimeBuilder::new().enable_timer(true).build()?;
        runtime.block_on(async {
            let listener = TcpListener::bind("127.0.0.1:8080")?;
            loop {
                let (stream, _) = listener.accept().await?;
                stream.set_nodelay(true)?;
                let conn = Http2::new(stream.into_poll()?, Http2Options::default());
                vibeio::spawn(async move {
                    let _ = conn
                        .handle(|_request| async move {
                            let response = Response::builder()
                                .status(StatusCode::OK)
                                .body(Full::new(Bytes::from_static(b"Hello World")))
                                .expect("valid response");
                            Ok::<_, std::convert::Infallible>(response)
                        })
                        .await;
                });
            }
        })
    }
}

#[cfg(feature = "h2")]
use server::*;
#[cfg(not(feature = "h2"))]
fn main() {
    unimplemented!("This example requires \"h2\" feature to be enabled.")
}