diff --git a/src/transforms/framing.js b/src/transforms/framing.js index a4fb0f7..45f0057 100644 --- a/src/transforms/framing.js +++ b/src/transforms/framing.js @@ -15,10 +15,10 @@ class Framer extends Transform { } _transform(chunk, enc, cb) { - var buffer = new Buffer(sizeOfVarInt(chunk.length)); + var buffer = new Buffer(sizeOfVarInt(chunk.length) + chunk.length); writeVarInt(chunk.length, buffer, 0); + chunk.copy(buffer, sizeOfVarInt(chunk.length)); this.push(buffer); - this.push(chunk); return cb(); } }