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

Browse Source
This commit is contained in:
Redkale
2017-05-25 16:50:46 +08:00
parent 31fca5630b
commit 27b67cde0e
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/org/redkale/net/http/WebSocketPacket.java
View File

@@ -102,11 +102,15 @@ public final class WebSocketPacket {
WebSocketPacket(ByteBuffer[] sendBuffers, FrameType type, boolean fin) { WebSocketPacket(ByteBuffer[] sendBuffers, FrameType type, boolean fin) {
this.type = type; this.type = type;
this.last = fin;
this.setSendBuffers(sendBuffers);
}
void setSendBuffers(ByteBuffer[] sendBuffers) {
this.sendBuffers = new ByteBuffer[sendBuffers.length]; this.sendBuffers = new ByteBuffer[sendBuffers.length];
for (int i = 0; i < sendBuffers.length; i++) { for (int i = 0; i < sendBuffers.length; i++) {
this.sendBuffers[i] = sendBuffers[i].duplicate(); this.sendBuffers[i] = sendBuffers[i].duplicate();
} }
this.last = fin;
} }
public WebSocketPacket(byte[] data) { public WebSocketPacket(byte[] data) {