fixes-8

src/main.rs

@@ -118,16 +118,18 @@ async fn sse_handler(
         pubsub.subscribe(format!("chat:{}", chat_id)).await.unwrap();
     }
 
-    let server_event = rx.recv().await.unwrap();
-
     let _: () = con
         .srem("authors-online", &author_id)
         .await
         .unwrap();
 
+    // Later in the sse_handler function
+    let server_event = rx.recv().await.unwrap();
+    let server_event_stream = futures::stream::once(async move { Ok::<_, actix_web::Error>(Bytes::from(server_event)) });
+
     HttpResponse::Ok()
         .append_header(("content-type", "text/event-stream"))
-        .streaming(server_event)
+        .streaming(server_event_stream)
 }
 
 #[actix_web::main]