Cleaned up Promise

src/streamHandler/InfluxPointWriter.js

@@ -25,10 +25,8 @@ class InfluxPointWriter extends Writable{
 
     _flush(next){
         this._api.flush(true)
-            .then(
+            .catch((err) => { next(new Error(`WriteApi rejected promise for flush: ${err}`)); })
-                next,
+            .then(next);
-                (err) => { next(new Error(`WriteApi rejected promise for flush: ${err}`)); }
-            );
     }
 }