修改websocket错误日志
This commit is contained in:
parent
c2515858a8
commit
887fec557b
@ -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 => {},
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user