This commit is contained in:
Naoyuki Kanezawa
2013-05-01 03:01:43 +09:00
parent 1200b464a1
commit 5b67b3f5dd

View File

@@ -429,7 +429,7 @@ public abstract class Socket extends Emitter {
!this.upgrading && this.writeBuffer.size() != 0) { !this.upgrading && this.writeBuffer.size() != 0) {
logger.info(String.format("flushing %d packets in socket", this.writeBuffer.size())); logger.info(String.format("flushing %d packets in socket", this.writeBuffer.size()));
this.prevBufferLen = this.writeBuffer.size(); this.prevBufferLen = this.writeBuffer.size();
this.transport.send(this.writeBuffer.toArray(new Packet[0])); this.transport.send(this.writeBuffer.toArray(new Packet[this.writeBuffer.size()]));
this.emit(EVENT_FLUSH); this.emit(EVENT_FLUSH);
} }
} }