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
use futures::StreamExt;
use std::convert::Infallible;
use std::time::Duration;
use tokio::time::interval;
use tokio_stream::wrappers::IntervalStream;
use warp::{sse::Event, Filter};
fn sse_counter(counter: u64) -> Result<Event, Infallible> {
Ok(warp::sse::Event::default().data(counter.to_string()))
}
#[tokio::main]
async fn main() {
pretty_env_logger::init();
let routes = warp::path("ticks").and(warp::get()).map(|| {
let mut counter: u64 = 0;
let interval = interval(Duration::from_secs(1));
let stream = IntervalStream::new(interval);
let event_stream = stream.map(move |_| {
counter += 1;
sse_counter(counter)
});
warp::sse::reply(event_stream)
});
warp::serve(routes).run(([127, 0, 0, 1], 3030)).await;
}