|
@ -150,25 +150,7 @@ function zlibBuffer(engine, buffer, callback) { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
function onEnd() { |
|
|
function onEnd() { |
|
|
var buffer; |
|
|
callback(null, Buffer.concat(buffers, nread)); |
|
|
switch (buffers.length) { |
|
|
|
|
|
case 0: |
|
|
|
|
|
buffer = new Buffer(0); |
|
|
|
|
|
break; |
|
|
|
|
|
case 1: |
|
|
|
|
|
buffer = buffers[0]; |
|
|
|
|
|
break; |
|
|
|
|
|
default: |
|
|
|
|
|
buffer = new Buffer(nread); |
|
|
|
|
|
var n = 0; |
|
|
|
|
|
buffers.forEach(function(b) { |
|
|
|
|
|
var l = b.length; |
|
|
|
|
|
b.copy(buffer, n, 0, l); |
|
|
|
|
|
n += l; |
|
|
|
|
|
}); |
|
|
|
|
|
break; |
|
|
|
|
|
} |
|
|
|
|
|
callback(null, buffer); |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
engine.on('error', onError); |
|
|
engine.on('error', onError); |
|
|