From 6d33a8a4866e7a63af9c92042a3ce1dc8636007d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E8=BF=90=E5=AE=B6?= Date: Sun, 11 May 2025 20:43:33 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96websocket=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/src/service/websocket_service.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/server/src/service/websocket_service.rs b/server/src/service/websocket_service.rs index 2d56790..8c1db13 100644 --- a/server/src/service/websocket_service.rs +++ b/server/src/service/websocket_service.rs @@ -88,10 +88,11 @@ pub async fn broadcast_message(msg: Message) { } /// 发送定向消息 -pub async fn send_message(msg: Message, accoudIds: Vec) { +#[allow(dead_code)] +pub async fn send_message(msg: Message, accoud_ids: Vec) { for ele in WS_POOL.iter() { let mut sender = ele.value().lock().await; - if accoudIds.contains(&ele.key().to_string()) { + if accoud_ids.contains(&ele.key().to_string()) { if let Err(err) = sender.send(msg.clone()).await { tracing::error!("Failed to send message: {:?}", err); }