Rust, Sse, Google.
warp::sse::Event; ​ async fn sse_events() -> impl warp::Reply { let mut interval = time::interval(Duration::from_secs(1)); futures::stream::unfold((), move |_| async move { interval.tick().await; Some((Event::default().data("hello"), ())) }) } In this example, we created an SSE event stream that