diff --git a/src/com/wentch/redkale/net/http/WebSocketGroup.java b/src/com/wentch/redkale/net/http/WebSocketGroup.java index 8126dd7ad..b79648c6d 100644 --- a/src/com/wentch/redkale/net/http/WebSocketGroup.java +++ b/src/com/wentch/redkale/net/http/WebSocketGroup.java @@ -92,10 +92,22 @@ public final class WebSocketGroup { 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) { return sendRecent(message, true); } + public final int sendRecent(WebSocketPacket packet) { + return recentWebSocket.send(packet); + } + public final int sendEach(Serializable message, boolean last) { int rs = 0; for (WebSocket s : list) {