amiya 0.0.6

experimental middleware-based minimalism async HTTP server framework
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
47
48
49
50
51
52
53

use {
    amiya::{async_trait, Context, Middleware, Result},
    std::time::Instant,
};

struct TimeMeasurer;

#[async_trait]
impl<Ex> Middleware<Ex> for TimeMeasurer
where
    Ex: Send + Sync + 'static,
{
    async fn handle(&self, mut ctx: Context<'_, Ex>) -> Result {
        let start = Instant::now();
        ctx.next().await?;
        let measure = format!("req; dur={}us", start.elapsed().as_micros());
        ctx.resp.append_header("server-timing", measure);
        Ok(())
    }
}

struct RequestHandler;

#[async_trait]
impl<Ex> Middleware<Ex> for RequestHandler
where
    Ex: Send + Sync + 'static,
{
    async fn handle(&self, mut ctx: Context<'_, Ex>) -> Result {
        ctx.next().await?;
        ctx.resp.set_body("Finish");
        Ok(())
    }
}

fn main() {
    let app = amiya::new().uses(TimeMeasurer).uses(RequestHandler);

    app.listen("[::]:8080").unwrap();

    std::thread::park();
}

// < HTTP/1.1 200 OK
// < content-length: 6
// < date: Thu, 23 Jul 2020 15:50:07 GMT
// < content-type: text/plain;charset=utf-8
// < server-timing: req;dur=9us                     <------------- Added by TimeMeasurer
// <
// * Connection #0 to host localhost left intact
// Finish* Closing connection 0                     <------------- Set by RequestHandler

// Referer to `examples/measurer_minimal.rs` to see how to macro `m` to achieve the same result