From 002a94afdccf29fd85abfee76026f7f7739d44b7 Mon Sep 17 00:00:00 2001 From: Tony Rewin Date: Mon, 2 Oct 2023 18:27:55 +0300 Subject: [PATCH] fixes-8 --- src/main.rs | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/main.rs b/src/main.rs index 2b593bf..019f53f 100644 --- a/src/main.rs +++ b/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]