fixed bug with incorrect await while emitting data

Author: Kirill

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

@@ -21,11 +21,13 @@ async function processAction(msg, cfg) {
     const results = [];
     split.forEach((elem) => results.push(elem));
     this.logger.info('Splitting the incoming message into %s messages', results.length);
-    results.forEach(async (result) => {
+
+    await Promise.all(results.map(async (result) => {
         if (result) {
             await this.emit('data', messages.newMessageWithBody(result));
         }
-    });
+    }));
+
     await this.emit('end');
 }