arturo-server - npm Package Compare versions

Comparing version 1.4.4 to 1.4.5

lib/utilities/Fork.js

@@ -47,15 +47,16 @@ 'use strict';
     key: '_write',
-    value: async function _write(_ref, enc, next) {
-      var path = _ref.path,
-          args = _ref.args,
-          opts = _ref.opts,
-          onSpawn = _ref.onSpawn,
-          onExit = _ref.onExit,
-          onDisconnect = _ref.onDisconnect,
-          onError = _ref.onError;
-
+    value: async function _write(input, enc, next) {
       var _this2 = this;
 
+      var path = input.path,
+          args = input.args,
+          opts = input.opts,
+          onSpawn = input.onSpawn,
+          onExit = input.onExit,
+          onDisconnect = input.onDisconnect,
+          onError = input.onError;
+
       // don't spin up queued workers
       // if we're destroying this stream
+
       if (this.destroyed) return;
@@ -68,3 +69,3 @@
         var defer = function defer() {
-          return _this2._write(args, enc, next);
+          return _this2._write(input, enc, next);
         };
@@ -71,0 +72,0 @@ this.once('child:exit', defer);

package.json

 {
   "name": "arturo-server",
-  "version": "1.4.4",
+  "version": "1.4.5",
   "description": "A database agnostic distributed job queue (server, client, and worker).",
@@ -5,0 +5,0 @@ "main": "lib/server/index.js",

src/utilities/Fork.js

@@ -18,11 +18,13 @@ import os from 'os'
 
-  async _write({
-    path,
-    args,
-    opts,
-    onSpawn,
-    onExit,
-    onDisconnect,
-    onError
-  }, enc, next) {
+  async _write(input, enc, next) {
+    const {
+      path,
+      args,
+      opts,
+      onSpawn,
+      onExit,
+      onDisconnect,
+      onError
+    } = input
+
     // don't spin up queued workers
@@ -36,3 +38,3 @@ // if we're destroying this stream
     if (this.active.length >= this.max) {
-      const defer = () => this._write(args, enc, next)
+      const defer = () => this._write(input, enc, next)
       this.once('child:exit', defer)
@@ -39,0 +41,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

351336

increased by0.01%

Lines of code

3945

increased by0.03%

No dependency changes