discours.io/quoter
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixes-21

Browse Source
This commit is contained in:
Tony Rewin 2023-10-02 23:34:30 +03:00
parent e6880f4c8c
commit 8145ed7a10
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main.rs
View File

@ -89,7 +89,7 @@ async fn create_first_chat(author_id: i32, con: &mut redis::aio::Connection) ->
async fn sse_handler( async fn sse_handler(
token: web::Path<String>, token: web::Path<String>,
mut rx: web::Data<Receiver<String>>, rx: web::Data<Receiver<String>>,
redis: web::Data<Client>, redis: web::Data<Client>,
) -> impl Responder { ) -> impl Responder {
let author_id = match get_auth_id(&token).await { 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, Ok(event) => event,
Err(e) => { Err(e) => {
eprintln!("Failed to receive server event: {}", e); eprintln!("Failed to receive server event: {}", e);