batch-cluster - npm Package Compare versions

Comparing version 5.6.4 to 5.6.5

CHANGELOG.md

@@ -20,2 +20,8 @@ # Changelog
 
+## v5.6.5
+
+- 📦 wrapped `stdin.write()` with try/catch that rejects the current task and
+  closes the current process.
+- 📦 wrapped `stdin.end()` with try/catch (as `.writable` isn't reliable)
+
 ## v5.6.4
@@ -32,3 +38,4 @@
 - 📦 Updated deps
-- 📦 Removed trace and debug log calls in `BatchProcess` (which incurred GC overhead even when disabled)
+- 📦 Removed trace and debug log calls in `BatchProcess` (which incurred GC
+  overhead even when disabled)
 
@@ -94,3 +101,4 @@ ## v5.6.1
 
-  There's a new `SimpleParser` implementation you can use that fails if `stderr` is non-blank or a stream matched the `.fail` pattern.
+  There's a new `SimpleParser` implementation you can use that fails if `stderr`
+  is non-blank or a stream matched the `.fail` pattern.
 
@@ -97,0 +105,0 @@ - 🐞 initial `BatchProcess` validation uses the new `SimpleParser` to verify the

dist/BatchProcess.js

@@ -236,4 +236,12 @@ "use strict";
         });
-        this.proc.stdin.write(cmd);
-        return true;
+        try {
+            this.proc.stdin.write(cmd);
+            return true;
+        }
+        catch (err) {
+            // child process went away. We should too.
+            // tslint:disable-next-line: no-floating-promises
+            this.end(false, "proc.stdin.write(cmd)");
+            return false;
+        }
     };
@@ -297,7 +305,5 @@ /**
                         cmd = Object_1.map(this.opts.exitCommand, function (ea) { return String_1.ensureSuffix(ea, "\n"); });
-                        if (this.proc.stdin != null && this.proc.stdin.writable) {
-                            this.proc.stdin.end(cmd);
-                        }
                         // proc cleanup:
                         Error_1.tryEach([
+                            function () { return Object_1.map(_this.proc.stdin, function (ea) { return ea.end(cmd); }); },
                             function () { return Object_1.map(_this.proc.stdout, function (ea) { return ea.destroy(); }); },
@@ -304,0 +310,0 @@ function () { return Object_1.map(_this.proc.stderr, function (ea) { return ea.destroy(); }); },

package.json

 {
   "name": "batch-cluster",
-  "version": "5.6.4",
+  "version": "5.6.5",
   "description": "Manage a cluster of child processes",
@@ -5,0 +5,0 @@ "main": "dist/BatchCluster.js",

No alert changes

Improved metrics

Total package byte prevSize

223634

increased by0.19%

Lines of code

2621

increased by0.23%

No dependency changes