Rust, Sse, Google.
sse_events(); // Call asynchronous function to get the event stream warp::sse::reply(warp::sse::keep_alive().stream(stream)) }); ​ warp::serve(sse_route).run(([127, 0, 0, 1], 3030)).await; } Implement the event stream logic: use futures::stream::StreamExt; use tokio::time::{self, Duration}; use