Handle closed channel in service

Author: Piotr Oleś

lib/cluster.js

@@ -58,7 +58,12 @@ workerIds.forEach(function (workerId) {
       merged.diagnostics = NormalizedMessage.deduplicate(merged.diagnostics);
       merged.lints = NormalizedMessage.deduplicate(merged.lints);
 
-      process.send(merged);
+      try {
+        process.send(merged);
+      } catch (e) {
+        // channel closed...
+        process.exit();
+      }
     }
   });
 });

lib/service.js

@@ -31,10 +31,15 @@ function run (cancellationToken) {
   }
 
   if (!cancellationToken.isCancellationRequested()) {
-    process.send({
-      diagnostics: diagnostics,
-      lints: lints
-    });
+    try {
+      process.send({
+        diagnostics: diagnostics,
+        lints: lints
+      });
+    } catch (e) {
+      // channel closed...
+      process.exit();
+    }
   }
 }