node-worker-pool - npm Package Compare versions

Comparing version 2.1.4 to 2.1.5

package.json

 {
   "name": "node-worker-pool",
-  "version": "2.1.4",
+  "version": "2.1.5",
   "dependencies": {
@@ -13,4 +13,4 @@ "q": "~0.9.7"
   "scripts": {
-    "test": "node node_modules/jest/bin/runTests.js --config=testConfig.json"
+    "test": "node node_modules/jest/bin/jest.js --config=testConfig.json"
   }
 }

README.md

@@ -63,5 +63,11 @@ # node-worker-pool
   var workerPool = new WorkerPool(
-    8, // number of workers
+    8,                // number of workers
     process.execPath, // path to the node binary
-    './worker.js' // path to the worker script
+    './worker.js',    // path to the worker script
+    {
+      // The initData object that is passed to each worker exactly once before
+      // any messages get sent. Workers receive this object via their
+      // onInitialize callback.
+      initData: {someUsefulConstant: 42}
+    }
   );
@@ -68,0 +74,0 @@

WorkerPool.js

@@ -50,10 +50,18 @@ "use strict";
       delete this._queuedWorkerSpecificMessages[workerID];
-      this._sendMessageToWorker(workerID, queuedMsg.msg).done(function(response) {
-        queuedMsg.deferred.resolve(response);
-      });
+      this._sendMessageToWorker(workerID, queuedMsg.msg)
+        .catch(function(err) {
+          queuedMsg.deferred.reject(err);
+        })
+        .done(function(response) {
+          queuedMsg.deferred.resolve(response);
+        });
     } else if (this._queuedMessages.length > 0) {
       var queuedMsg = this._queuedMessages.shift();
-      this._sendMessageToWorker(workerID, queuedMsg.msg).done(function(response) {
-        queuedMsg.deferred.resolve(response);
-      })
+      this._sendMessageToWorker(workerID, queuedMsg.msg)
+        .catch(function(err) {
+          queuedMsg.deferred.reject(err);
+        })
+        .done(function(response) {
+          queuedMsg.deferred.resolve(response);
+        })
     } else {
@@ -60,0 +68,0 @@ this._availableWorkers.push(workerID);

No alert changes

Improved metrics

Total package byte prevSize

15020

increased by3.04%

Lines of code

370

increased by2.21%

Number of lines in readme file

83

increased by7.79%

No dependency changes