From 8145ed7a1044d9acd2ba1a3c8a91f8a234a34a1a Mon Sep 17 00:00:00 2001 From: Tony Rewin Date: Mon, 2 Oct 2023 23:34:30 +0300 Subject: [PATCH] fixes-21 --- src/main.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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);