wangliwen
/
share-platform
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Merge branch 'dev'

This commit is contained in:
wangliwen 2022-07-28 10:44:26 +08:00
parent ac4347687f ee1d2550d3
commit 5349c03e91
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
renren-admin/src/main/java/io/renren/websocket/WebSocketServer.java
View File

@ -76,11 +76,11 @@ public class WebSocketServer {
* @param message 消息内容
*/
public void sendMessage(Long userId, MessageData<?> message) {
servers.values().forEach(info -> {
if (userId.equals(info.getUserId())) {
sendMessage(info.getSession(), message);
}
});
servers.values().stream()
.filter(index -> userId.equals(index.getUserId()))
.forEach(index -> {
sendMessage(index.getSession(), message);
});
}
/**