From 4cc14687e0a498b1bbe99e17731765e19e19257b Mon Sep 17 00:00:00 2001 From: ZhenYi <434836402@qq.com> Date: Fri, 1 May 2026 01:14:00 +0800 Subject: [PATCH] feat(ai): add comprehensive AI streaming and non-streaming processing services --- libs/room/src/service/ai_streaming.rs | 3 --- 1 file changed, 3 deletions(-) diff --git a/libs/room/src/service/ai_streaming.rs b/libs/room/src/service/ai_streaming.rs index c4412ee..ed8c690 100644 --- a/libs/room/src/service/ai_streaming.rs +++ b/libs/room/src/service/ai_streaming.rs @@ -67,12 +67,10 @@ pub async fn process_message_ai_streaming( let ai_display_name_for_final = ai_display_name.clone(); let chunk_count = std::sync::Arc::new(std::sync::atomic::AtomicU64::new(0)); - let room_manager_cb = room_manager.clone(); let queue_for_chunk = queue.clone(); let on_chunk = move |chunk: agent::chat::AiStreamChunk| { Box::pin({ - let room_manager = room_manager_cb.clone(); let queue = queue_for_chunk.clone(); let streaming_msg_id = streaming_msg_id; let room_id = room_id_inner; @@ -102,7 +100,6 @@ pub async fn process_message_ai_streaming( chunk_type: Some(chunk_type_str.to_string()), }; queue.publish_stream_chunk(&event).await; - room_manager.broadcast_stream_chunk(event).await; } }) as Pin + Send>> };