From 44cd3288cf95ef862de8c22f2c909e0b8b3ca721 Mon Sep 17 00:00:00 2001 From: Ruakij Date: Fri, 26 Nov 2021 17:33:19 +0100 Subject: [PATCH] Fixed stram not being in object-mode --- src/streamHandler/InfluxPointWriter.js | 4 ++++ 1 file changed, 4 insertions(+) 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} options Options for WriteApi */ + constructor(influxDb, org, bucket, options){ + super({ + objectMode: true + }); this._api = influxDb.getWriteApi(org, bucket, 'us', options); }