@ -47,6 +47,12 @@ class PacketStreamFactory extends Transform{
}
_transform(chunk, encoding, next){
if(!chunk){
const err = "Chunk was invalid!";
logger.error(err);
next(err);
let packet = new Packet();
const lines = chunk.split("\n");