diff --git a/src/main.rs b/src/main.rs index 27f288d..f54f67c 100644 --- a/src/main.rs +++ b/src/main.rs @@ -52,7 +52,8 @@ async fn main() { events_clients.lock().unwrap().push(tx); let stream = stream::select( - interval(Duration::from_secs(5)).map(move |_| { + interval(Duration::from_secs(3)).map(move |_| { + trace!("sending sse keepalive ping"); Ok::<_, Infallible>((sse::event("ping"), sse::data("")).into_a()) }),