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

use amiya::m;

// Extra data of Amiya must be Default + Send + Sync, and can't contain reference
#[derive(Default)]
struct ExData {
    header_ext_message: Option<String>,
}

fn main() {
    let app = amiya::with_ex()
        // Amiya support extra data attach in context, just set it's type as second argument
        .uses(m!(ctx: ExData => {
            println!(
                "Request {} from {}",
                ctx.req.url(),
                ctx.req.remote().unwrap_or("unknown address")
            );
            // then you can use ctx.ex to communicate with other middleware
            ctx.ex.header_ext_message.replace(String::from("Amiya Middleware ExData Test"));
            let result = ctx.next().await;
            if let Err(ref err) = result {
                eprintln!("Request process error: {}", err);
            }
            result
        }))
        .uses(m!(ctx: ExData => {
            ctx.next().await?;
            ctx.resp.set_body("Hello from Amiya!");
            // get message set by other middleware and use it 
            if let Some(message) = ctx.ex.header_ext_message.take() {
                ctx.resp.insert_header("X-Amiya-Ext", message);
            }
            Ok(())
        }));

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

    std::thread::park();
}