diff --git a/src/streamHandler/InfluxPointWriter.js b/src/streamHandler/InfluxPointWriter.js
index fbf64cc..9bd96ad 100644
--- a/src/streamHandler/InfluxPointWriter.js
+++ b/src/streamHandler/InfluxPointWriter.js
@@ -13,6 +13,10 @@ class InfluxPointWriter extends Writable{
      * @param {string} bucket Bucket to use
      * @param {Partial<WriteOptions>} options Options for WriteApi
      */
+    constructor(influxDb, org, bucket, options){
+        super({
+            objectMode: true
+        });
         this._api = influxDb.getWriteApi(org, bucket, 'us', options);
     }