From 1ddb707a9bb8530875d9d3908beb2832877bfd16 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Wed, 4 Mar 2026 12:35:22 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=20WebSocket=20=E6=B6=88?= =?UTF-8?q?=E6=81=AF=E5=8F=91=E9=80=81=EF=BC=9A=E7=A7=BB=E9=99=A4=E4=B8=8D?= =?UTF-8?q?=E5=BF=85=E8=A6=81=E7=9A=84=20clone=EF=BC=8C=E6=B3=A8=E9=87=8A?= =?UTF-8?q?=E6=8E=89=20send=5Fto=5Fclient?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/event.rs | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/event.rs b/src/event.rs index 8de25db..6d26aa6 100644 --- a/src/event.rs +++ b/src/event.rs @@ -168,13 +168,14 @@ impl EventManager { if let Some(ws_manager) = &ws_manager_clone { let ws_message = crate::websocket::WsMessage::PointNewValue(monitor); - if let Err(e) = ws_manager.send_to_public(ws_message.clone()).await { + if let Err(e) = ws_manager.send_to_public(ws_message).await { tracing::error!("Failed to send WebSocket message to public room: {}", e); } - if let Err(e) = ws_manager.send_to_client(point_id, ws_message).await { - tracing::error!("Failed to send WebSocket message to client room {}: {}", point_id, e); - } + // 暂时注释掉 send_to_client，因为现在信息只需发送到 public + // if let Err(e) = ws_manager.send_to_client(point_id, ws_message).await { + // tracing::error!("Failed to send WebSocket message to client room {}: {}", point_id, e); + // } } } else { tracing::warn!("Point not found for source {} client_handle {}", source_id, client_handle);