Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 6c848c0e42 | |||
| 918306647d | |||
| 1bc52b0a37 | |||
| 3b10aca352 |
@@ -47,8 +47,15 @@ class PacketStreamFactory extends Transform{
|
||||
}
|
||||
|
||||
_transform(chunk, encoding, next){
|
||||
let packet = new Packet();
|
||||
if(!chunk){
|
||||
const err = "Chunk was invalid!";
|
||||
logger.error(err);
|
||||
next(err);
|
||||
return;
|
||||
}
|
||||
|
||||
let packet = new Packet();
|
||||
|
||||
const lines = chunk.split("\n");
|
||||
const header = lines.splice(0, 1)[0]; // Grab first line, "lines" is now the payload
|
||||
packet = this._handleHeader(packet, header);
|
||||
|
||||
Reference in New Issue
Block a user