feat: add std stream event emit for abort handlers

src/WorkerHandler.js

@@ -220,13 +220,15 @@ function objectToError (obj) {
 
 function handleEmittedStdPayload(handler, payload) {
   // TODO: refactor if parallel task execution gets added
-  if (Object.keys(handler.processing).length !== 1) {
-    return;
-  }
   var task = Object.values(handler.processing)[0]
-  if (task.options && typeof task.options.on === 'function') {
+  if (task && task.options && typeof task.options.on === 'function') {
     task.options.on(payload);
   }
+
+  task = Object.values(handler.tracking)[0];
+  if (task && task.options && typeof task.options.on === "function") {
+    task.options.on(payload);
+  } 
 }
 
 /**
@@ -422,7 +424,8 @@ WorkerHandler.prototype.exec = function(method, params, resolver, options) {
     if (error instanceof Promise.CancellationError || error instanceof Promise.TimeoutError) {
       me.tracking[id] = {
         id,
-        resolver: Promise.defer()
+        resolver: Promise.defer(),
+        options: me.processing[id].options,
       };
 
       // remove this task from the queue. It is already rejected (hence this

test/Pool.test.js

@@ -1354,7 +1354,7 @@ describe('Pool', function () {
         maxWorkers: 1,
         onCreateWorker: () => {
           workerCount += 1;
-        }
+        },
       });
 
       let task = pool.exec('asyncTimeout', [],  {});
@@ -1559,6 +1559,25 @@ describe('Pool', function () {
         });
       });
     });
+
+    it('should trigger event stdout in abort handler', function (done) {
+      var pool = createPool(__dirname + '/workers/cleanup-abort.js', {
+        maxWorkers: 1,
+        workerType: 'process',
+        emitStdStreams: true, 
+        workerTerminateTimeout: 1000,
+      });
+
+      pool.exec('stdoutStreamOnAbort', [], {
+        on: function (payload) {
+          assert.strictEqual(payload.stdout.trim(), "Hello, world!");
+          console.log(payload);
+          pool.terminate();
+          done();
+        }
+      }).timeout(100);
+
+    });
   });
 
   describe('validate', () => {

test/workers/cleanup-abort.js

@@ -5,8 +5,7 @@ function asyncTimeout() {
   return new Promise(function (resolve) {
     let timeout = setTimeout(() => {
         resolve();
-    }, 5000); 
-
+    }, 5000);
     me.worker.addAbortListener(async function () {
         clearTimeout(timeout);
         resolve();
@@ -34,11 +33,26 @@ function asyncAbortHandlerNeverResolves() {
   });
 }
 
+function stdoutStreamOnAbort() {
+  var me = this;
+  return new Promise(function (resolve) {
+    let timeout = setTimeout(() => {
+      resolve();
+    }, 5000); 
+
+    me.worker.addAbortListener(async function () {
+        console.log("Hello, world!");
+        resolve();
+    });
+  });
+}
+
 // create a worker and register public functions
 workerpool.worker(
   {
     asyncTimeout: asyncTimeout,
     asyncAbortHandlerNeverResolves: asyncAbortHandlerNeverResolves,
+    stdoutStreamOnAbort: stdoutStreamOnAbort,
   },
   {
     abortListenerTimeout: 1000