This commit is contained in:
@@ -165,7 +165,7 @@ public final class WebSocketPacket {
|
|||||||
buffer.put(content, 0, buffer.remaining());
|
buffer.put(content, 0, buffer.remaining());
|
||||||
buffer.flip();
|
buffer.flip();
|
||||||
final int capacity = buffer.capacity();
|
final int capacity = buffer.capacity();
|
||||||
final ByteBuffer[] buffers = new ByteBuffer[pend / capacity + 1];
|
final ByteBuffer[] buffers = new ByteBuffer[(pend / capacity) + 1 + ((pend % capacity) > 0 ? 1 : 0)];
|
||||||
buffers[0] = buffer;
|
buffers[0] = buffer;
|
||||||
for (int i = 1; i < buffers.length; i++) {
|
for (int i = 1; i < buffers.length; i++) {
|
||||||
ByteBuffer buf = supplier.get();
|
ByteBuffer buf = supplier.get();
|
||||||
|
|||||||
Reference in New Issue
Block a user