diff --git a/src/main.rs b/src/main.rs
index 30f8262..a9069a4 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -6,7 +6,7 @@ use serde_json::Value;
 use std::collections::HashMap;
 use std::env;
 use std::error::Error;
-use futures::{StreamExt, FutureExt};
+use futures::StreamExt;
 use tokio::sync::broadcast::{self, Receiver};
 
 #[derive(Debug, Serialize, Deserialize)]
@@ -54,7 +54,7 @@ async fn get_auth_id(token: &str) -> Result<i32, Box<dyn Error>> {
 
 async fn sse_handler(
     token: web::Path<String>,
-    rx: web::Data<Receiver<String>>,
+    mut rx: web::Data<Receiver<String>>,
     redis: web::Data<Client>,
 ) -> impl Responder {
     let author_id = match get_auth_id(&token).await {
@@ -81,7 +81,6 @@ async fn sse_handler(
         pubsub.subscribe(format!("message:{}", chat_id)).await.unwrap();
     }
 
-    let mut rx = rx.get_ref().subscribe();
     let server_event = rx.recv().await.unwrap();
 
     let _: () = con
@@ -96,7 +95,7 @@ async fn sse_handler(
 
 #[actix_web::main]
 async fn main() -> std::io::Result<()> {
-    let (tx, mut rx) = broadcast::channel(100);
+    let (tx, _rx) = broadcast::channel(100);
     let redis_url = env::var("REDIS_URL").unwrap();
     let client = redis::Client::open(redis_url).unwrap();
     let _handle = tokio::spawn(async move {