Cleaner message stream reading
This commit is contained in:
parent
47892ab6d8
commit
6d310ef968
@ -24,10 +24,7 @@ var readFlowingBytes = function(stream, amount, preRead, callback){
|
|||||||
buff = Buffer.concat([buff, data], 2);
|
buff = Buffer.concat([buff, data], 2);
|
||||||
if (buff.length >= amount){
|
if (buff.length >= amount){
|
||||||
var returnData = buff.slice(0, amount);
|
var returnData = buff.slice(0, amount);
|
||||||
var lopped;
|
var lopped = buff.length > amount ? buff.slice(amount): null;
|
||||||
|
|
||||||
if (buff.length > amount)
|
|
||||||
lopped = buff.slice(amount);
|
|
||||||
callback(returnData, lopped);
|
callback(returnData, lopped);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user