rweb 0.15.0

Yet another web server framework for rust
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

use rweb::{filters::sse::Event, get, Reply};
use std::{convert::Infallible, time::Duration};
use tokio::time::interval;
use tokio_stream::{wrappers::IntervalStream, StreamExt};

// create server-sent event
fn sse_counter(counter: u64) -> Result<Event, Infallible> {
    Ok(Event::default().data(counter.to_string()))
}

#[get("/ticks")]
fn ticks() -> impl Reply {
    let mut counter: u64 = 0;
    // create server event source
    let event_stream = IntervalStream::new(interval(Duration::from_secs(1))).map(move |_| {
        counter += 1;
        sse_counter(counter)
    });
    // reply using server-sent events
    rweb::sse::reply(event_stream)
}

#[tokio::main]
async fn main() {
    pretty_env_logger::init();

    rweb::serve(ticks()).run(([127, 0, 0, 1], 3030)).await;
}