Merge pull request #36 from elasticio/sprint-33-issue-35

fix bug with incorrect await while emitting data

Author: kirill-levitskiy

CHANGELOG.md

@@ -1,3 +1,7 @@
+## 1.0.4 (February 03, 2020)
+
+* Fixed bug with incorrect await while emitting data
+
 ## 1.0.3 (December 24, 2019)
 
 * Update sailor version to 2.5.4

lib/actions/splitOnJsonata.js

@@ -18,15 +18,14 @@ async function processAction(msg, cfg) {
         return;
     }
 
-    const results = [];
-    split.forEach((elem) => results.push(elem));
-    this.logger.info('Splitting the incoming message into %s messages', results.length);
-    results.forEach(async (result) => {
-        if (result) {
-            await this.emit('data', messages.newMessageWithBody(result));
+    this.logger.info('Splitting the incoming message into %s messages', split.length);
+
+    for (let i = 0; i < split.length; i += 1) {
+        if (split[i]) {
+            // eslint-disable-next-line no-await-in-loop
+            await this.emit('data', messages.newMessageWithBody(split[i]));
         }
-    });
-    await this.emit('end');
+    }
 }
 
 exports.process = processAction;