serv 0.2.0

oneshot-style HTTP API builder
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

extern crate hyper;
#[macro_use]
extern crate serde_derive;
extern crate serv;
extern crate tokio;
extern crate tokio_timer;

use std::time::*;

use hyper::rt::Future;

#[derive(Serialize)]
struct HelloResp {
    msg: String,
}

fn hello(_req: serv::Empty) -> Box<Future<Item = HelloResp, Error = serv::Error>> {
    let delay = Instant::now() + Duration::from_secs(1);
    let f = tokio_timer::Delay::new(delay).then(|_| {
        Ok(HelloResp {
            msg: "hello, world".to_owned(),
        })
    });
    Box::new(f)
}

fn main() {
    use serv::server::{Routes, Server};
    let addr = ([127, 0, 0, 1], 3000).into();

    let mut routes = Routes::new();
    routes.push(hyper::Method::GET, "/", serv::async::serv(hello));
    let server = Server::new(routes);

    let server = hyper::server::Server::bind(&addr)
        .serve(move || Ok::<_, hyper::Error>(server.clone()))
        .map_err(|e| eprintln!("failed to serve: {:?}", e));

    let mut rt = tokio::runtime::current_thread::Runtime::new().expect("failed to create runtime");
    rt.block_on(server).expect("error on runtime");
}