Fixed wrong push

3 years ago · 3af4bb7cc6
parent 2a662e0bd1
commit 3af4bb7cc6
1 changed files with 1 additions and 1 deletions
--- a/src/streamHandler/PacketInfluxPointFactory.js
+++ b/src/streamHandler/PacketInfluxPointFactory.js
@ -47,7 +47,7 @@ class PacketInfluxPointFactory extends Transform{

            point.setField('value', packet[objKey]);        // Set field

-            this.push(null, point);     // Push point into stream
+            this.push(point);     // Push point into stream
        });
        
        next();     // Get next packet