micro-web 0.3.0

the async micro web 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

use futures::Stream;
use micro_web::encoding::encoder::EncodeDecorator;
use micro_web::responder::sse::{build_sse_stream_emitter, Event, SseStream};
use micro_web::router::{get, Router};
use micro_web::Server;

async fn sse_process() -> SseStream<impl Stream<Item = Event>> {
    let (stream, mut emitter) = build_sse_stream_emitter(2);

    tokio::spawn(async move {
        for i in 0..5 {
            tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
            let _ = emitter.send(Event::from_data(format!("{}", i))).await;
        }

        let _ = emitter.close().await;
    });

    stream
}

async fn default_handler() -> &'static str {
    "404 not found"
}

#[tokio::main]
async fn main() {
    // Build router with multiple routes and handlers
    let router = Router::builder()
        // Basic GET route
        .route("/sse", get(sse_process))
        // Add response encoding wrapper
        .with_global_decorator(EncodeDecorator)
        .build();

    // Configure and start the server
    Server::builder().router(router).bind("127.0.0.1:8080").default_handler(default_handler).build().unwrap().start().await;
}