Compare commits
11 Commits
f_influxdb
...
v2.1.1
| Author | SHA1 | Date | |
|---|---|---|---|
| 1bc52b0a37 | |||
| 3b10aca352 | |||
| b1942b89cb | |||
| 10bd72907e | |||
| 5303b31bd7 | |||
| c3cd6393d4 | |||
| c97137f4a7 | |||
| a13d81e9c0 | |||
| 059c02e243 | |||
| a610f209d5 | |||
| 6e05a0b45c |
@@ -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");
|
||||
|
||||
Reference in New Issue
Block a user