diff --git a/src/main.rs b/src/main.rs index ad7fe7a..be2d131 100644 --- a/src/main.rs +++ b/src/main.rs @@ -89,7 +89,7 @@ async fn create_first_chat(author_id: i32, con: &mut redis::aio::Connection) -> async fn sse_handler( token: web::Path, - mut rx: web::Data>, + rx: web::Data>, redis: web::Data, ) -> impl Responder { let author_id = match get_auth_id(&token).await { @@ -158,7 +158,7 @@ async fn sse_handler( } }; - let server_event = match rx.recv().await { + let server_event = match Arc::clone(&rx).recv().await { Ok(event) => event, Err(e) => { eprintln!("Failed to receive server event: {}", e);