This commit is contained in:
李运家 2025-04-20 08:22:12 +08:00
commit 9fd55c68b3

View File

@ -9,7 +9,6 @@ use futures::stream::{SplitSink, SplitStream};
use futures::{SinkExt, StreamExt};
use lazy_static::lazy_static;
use library::context::Context;
use library::model::response::{ResErr, ResResult};
lazy_static!{
static ref WS_POOL: DashMap<String, Arc<Mutex<SplitSink<WebSocket, Message>>>> = DashMap::<String, Arc<Mutex<SplitSink<WebSocket, Message>>>>::new();
@ -49,7 +48,7 @@ async fn read(account_id: String, mut receiver: SplitStream<WebSocket>) {
}
},
Some(Err(err)) => {
tracing::error!("读取消息失败 {:?}", err);
tracing::error!("用户 {:?}读取消息失败 {:?}", account_id, err);
}
None => {},
}