diff --git a/src/main.rs b/src/main.rs index a1e8e0a..458e95c 100644 --- a/src/main.rs +++ b/src/main.rs @@ -10,7 +10,6 @@ use futures::StreamExt; use tokio::sync::broadcast::{self, Receiver}; use uuid::Uuid; use chrono::Utc; -use std::borrow::Borrow; #[derive(Debug, Serialize, Deserialize)] #[serde(rename_all = "snake_case")] @@ -165,7 +164,7 @@ async fn sse_handler( } }; - let server_event = match rx.get_ref().recv().await { + let server_event = match rx.recv().await { Ok(event) => event, Err(e) => { eprintln!("Failed to receive server event: {}", e);