diff --git a/src/main.rs b/src/main.rs index 458e95c..1133500 100644 --- a/src/main.rs +++ b/src/main.rs @@ -164,7 +164,7 @@ async fn sse_handler( } }; - let server_event = match rx.recv().await { + let server_event = match rx.as_ref().clone().recv().await { Ok(event) => event, Err(e) => { eprintln!("Failed to receive server event: {}", e);