diff --git a/src/cores/servers/actix_web/mod.rs b/src/cores/servers/actix_web/mod.rs index 54c41dcdd8ea4683652a7d92b36190b3b82947c5..e6c4321a9d117de3ff5e94f2a26c1db957e7dc60 100644 --- a/src/cores/servers/actix_web/mod.rs +++ b/src/cores/servers/actix_web/mod.rs @@ -263,7 +263,7 @@ macro_rules! define_json_stream_response_method { match serde_json::to_string(&value) { Ok(json) => { // 格式化为 SSE 的 data 字段,注意末尾的两个换行符 - let data = format!("{}\n\n", json); + let data = format!("data: {}\n\n", json); Ok(Bytes::from(data)) } Err(e) => { @@ -308,7 +308,7 @@ macro_rules! define_json_stream_response_method { match serde_json::to_string(&value) { Ok(json) => { // 格式化为 SSE 的 data 字段,注意末尾的两个换行符 - let data = format!("{}\n\n", json); + let data = format!("data: {}\n\n", json); Ok(Bytes::from(data)) } Err(e) => {