diff --git a/src/org/redkale/net/http/WebSocketPacket.java b/src/org/redkale/net/http/WebSocketPacket.java index bcb0ad56b..8b5e45bb9 100644 --- a/src/org/redkale/net/http/WebSocketPacket.java +++ b/src/org/redkale/net/http/WebSocketPacket.java @@ -102,11 +102,15 @@ public final class WebSocketPacket { WebSocketPacket(ByteBuffer[] sendBuffers, FrameType type, boolean fin) { this.type = type; + this.last = fin; + this.setSendBuffers(sendBuffers); + } + + void setSendBuffers(ByteBuffer[] sendBuffers) { this.sendBuffers = new ByteBuffer[sendBuffers.length]; for (int i = 0; i < sendBuffers.length; i++) { this.sendBuffers[i] = sendBuffers[i].duplicate(); } - this.last = fin; } public WebSocketPacket(byte[] data) {