Compare commits
10
Commits
dev
...
1bc52b0a37
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1bc52b0a37 | ||
|
|
3b10aca352 | ||
|
|
b1942b89cb | ||
|
|
5303b31bd7 | ||
|
|
c3cd6393d4 | ||
|
|
c97137f4a7 | ||
|
|
a13d81e9c0 | ||
|
|
059c02e243 | ||
|
|
a610f209d5 | ||
|
|
6e05a0b45c |
@@ -47,8 +47,14 @@ class PacketStreamFactory extends Transform{
|
|||||||
}
|
}
|
||||||
|
|
||||||
_transform(chunk, encoding, next){
|
_transform(chunk, encoding, next){
|
||||||
let packet = new Packet();
|
if(!chunk){
|
||||||
|
const err = "Chunk was invalid!";
|
||||||
|
logger.error(err);
|
||||||
|
next(err);
|
||||||
|
}
|
||||||
|
|
||||||
|
let packet = new Packet();
|
||||||
|
|
||||||
const lines = chunk.split("\n");
|
const lines = chunk.split("\n");
|
||||||
const header = lines.splice(0, 1)[0]; // Grab first line, "lines" is now the payload
|
const header = lines.splice(0, 1)[0]; // Grab first line, "lines" is now the payload
|
||||||
packet = this._handleHeader(packet, header);
|
packet = this._handleHeader(packet, header);
|
||||||
|
|||||||
Reference in New Issue
Block a user