lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
地平线
2015-09-21 10:24:18 +08:00
parent 3b8dc74504
commit 8285a02373
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/com/wentch/redkale/net/http/WebSocketGroup.java
View File

@@ -92,10 +92,22 @@ public final class WebSocketGroup {
return sendEach(message, true); return sendEach(message, true);
} }
public final int sendEach(WebSocketPacket packet) {
int rs = 0;
for (WebSocket s : list) {
rs |= s.send(packet);
}
return rs;
}
public final int sendRecent(Serializable message) { public final int sendRecent(Serializable message) {
return sendRecent(message, true); return sendRecent(message, true);
} }
public final int sendRecent(WebSocketPacket packet) {
return recentWebSocket.send(packet);
}
public final int sendEach(Serializable message, boolean last) { public final int sendEach(Serializable message, boolean last) {
int rs = 0; int rs = 0;
for (WebSocket s : list) { for (WebSocket s : list) {