Compare commits
13 Commits
f_influxdb
...
v2.1.2
| Author | SHA1 | Date | |
|---|---|---|---|
| 6c848c0e42 | |||
| 918306647d | |||
| 1bc52b0a37 | |||
| 3b10aca352 | |||
| b1942b89cb | |||
| 10bd72907e | |||
| 5303b31bd7 | |||
| c3cd6393d4 | |||
| c97137f4a7 | |||
| a13d81e9c0 | |||
| 059c02e243 | |||
| a610f209d5 | |||
| 6e05a0b45c |
@@ -47,6 +47,13 @@ class PacketStreamFactory extends Transform{
|
|||||||
}
|
}
|
||||||
|
|
||||||
_transform(chunk, encoding, next){
|
_transform(chunk, encoding, next){
|
||||||
|
if(!chunk){
|
||||||
|
const err = "Chunk was invalid!";
|
||||||
|
logger.error(err);
|
||||||
|
next(err);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
let packet = new Packet();
|
let packet = new Packet();
|
||||||
|
|
||||||
const lines = chunk.split("\n");
|
const lines = chunk.split("\n");
|
||||||
|
|||||||
Reference in New Issue
Block a user