Merge pull request #10 from Edujugon/dev

add constants

package.json

@@ -1,6 +1,6 @@
 {
   "name": "node-parallelizer",
-  "version": "2.0.0",
+  "version": "2.1.1",
   "description": "A NodeJS package for running code in parallel. Initially created to provide multiprocessing in an AWS Lambda function, but it can be used in any NodeJS environment.",
   "main": "src/index.js",
   "scripts": {

src/child-process.js

@@ -73,7 +73,7 @@ class ChildProcess {
   async _processBatchesInForks(batches) {
     const batchesCount = batches.length;
     const childResponses = {
-      childResponses: [],
+      responses: [],
       failures: []
     };
 
@@ -145,7 +145,7 @@ class ChildProcess {
             })
             childResponses.failures.push(errorMessage);
           } else if (status == 'SUCCESS') {
-            childResponses.childResponses.push(reponse);
+            childResponses.responses.push(reponse);
           }
 
           if (++responsesReceived == batchesCount) {

src/index.js

@@ -3,6 +3,7 @@ const WorkerThreads = require("./worker-thread");
 
 const PARALLELIZER_CHILD = 'child-process';
 const PARALLELIZER_THREADS = 'worker-threads';
+
 class Parallelizer {
   constructor(params) {
     const parallelizer = params.type;
@@ -14,4 +15,4 @@ class Parallelizer {
     }
   }
 }
-module.exports = { ChildProcess, WorkerThreads, Parallelizer };
+module.exports = { ChildProcess, WorkerThreads, Parallelizer, PARALLELIZER_CHILD, PARALLELIZER_THREADS };

src/worker-thread.js

@@ -48,16 +48,16 @@ class WorkerThreads {
     await new Promise((resolve, reject) => {
       for (let id = 0; id < batchesCount; id++) {
         const worker = new Worker(this.tmpPath, { workerData: { id, batch: batches[id] } });
-        worker.on('error', reject);
-        worker.on('exit', (code) => {
+        worker.on('error', (error) => {
           logger({
-            message: `Worker Thread #${id} exited with code: ${code}`,
+            message: `Thread #${id} error message: ${error.message}`,
             params: {
               thread_id: id,
-              exit_code: code
+              error_message: error.message
             },
             debug: this.debug
           })
+          threadResponses.failures.push(error.message);
 
           // In case a thread exists without sending a message.
           if (++responsesReceived == batchesCount) {