fix-sse-protocol

2023-10-19 12:16:08 +03:00
parent 6c0f84749e
commit bf442e01c9
2 changed files with 4 additions and 2 deletions
--- a/src/main.rs
+++ b/src/main.rs
@@ -128,7 +128,10 @@ async fn connect_handler(
    let server_event_stream = futures::stream::unfold(rx, |mut rx| async {
        let result = rx.recv().await;
        match result {
-            Ok(server_event) => Some((Ok::<_, actix_web::Error>(Bytes::from(server_event)), rx)),
+            Ok(server_event) => {
+                let formatted_server_event = format!("data: {}\n\n", server_event);
+                Some((Ok::<_, actix_web::Error>(Bytes::from(formatted_server_event)), rx))
+            },
            Err(_) => None,
        }
    });