Fix problem in node 13.x version
authoraardizio <alessandroardizio94@gmail.com>
Wed, 22 Jan 2020 19:01:28 +0000 (20:01 +0100)
committeraardizio <alessandroardizio94@gmail.com>
Wed, 22 Jan 2020 19:01:28 +0000 (20:01 +0100)
lib/workers.js
package.json

index 0e8569e5423e3b91617d564e2a80cfde4c3aa45c..103061aa78b55e55625eb877f81b300239116d14 100644 (file)
@@ -27,7 +27,7 @@ class ThreadWorker extends AsyncResource {
       if (value && value.data && value._id) {
         // here you will receive messages
         // console.log('This is the main thread ' + isMainThread)
-        this._run(fn, value)
+        this.runInAsyncScope(this._run.bind(this), this, fn, value)
       } else if (value.parent) {
         // save the port to communicate with the main thread
         // this will be received once
@@ -48,7 +48,7 @@ class ThreadWorker extends AsyncResource {
 
   _run (fn, value) {
     try {
-      const res = this.runInAsyncScope(fn, null, value.data)
+      const res = fn(value.data)
       this.parent.postMessage({ data: res, _id: value._id })
       this.lastTask = Date.now()
     } catch (e) {
index f8e74782beffa0f773dac8bf72197a2a57867921..dbf9425db2107a79c654d692b01d3f491f31cd9b 100644 (file)
@@ -6,7 +6,7 @@
   "scripts": {
     "build": "npm install",
     "test": "standard && nyc mocha --exit --timeout 20000 tests/*test.js ",
-    "debug-test": "mocha --inspect-brk --experimental-worker --exit tests/*test.js ",
+    "debug-test": "mocha --inspect-brk --exit tests/*test.js ",
     "demontest": "nodemon --exec \"npm test\"",
     "coverage": "nyc report --reporter=text-lcov tests/*test.js | coveralls",
     "standard-verbose": "npx standard --verbose",