ref: cleamup examples

examples/abort.js

@@ -14,7 +14,7 @@ const pool = workerpool.pool(__dirname + "/workers/cleanupAbort.js", {
   maxWorkers: 1,
 });
 
-const main = async () => {
+const main = async function() {
   let abortResolverSuccess;
   await pool
     .exec("asyncTimeout", [], {
@@ -34,8 +34,8 @@ const main = async () => {
       console.log("timeout handled: ", err.message);
     });
 
-  await abortResolverSuccess.catch((err) => {
-    console.log("abort operation concluded ", err);
+  await abortResolverSuccess.then((err) => {
+    console.log("abort operation resolved for asyncTimeout");
   });
 
   console.log("pool status after abort operation:", pool.stats());
@@ -61,8 +61,9 @@ const main = async () => {
       console.log("cancel occured: ", err.message);
     });
 
-  await abortResolverFailure.catch((e) => {
-    console.log("cancelation handled: ", e.message);
+
+  await abortResolverFailure.then(() => {
+    console.log("cancelation handled for asyncAbortHandlerNeverResolves");
   });
 
   console.log("final pool stats", pool.stats());

examples/workers/cleanupAbort.js

@@ -5,7 +5,7 @@ function asyncTimeout() {
   return new Promise(function (resolve) {
     let timeout = setTimeout(() => {
         resolve();
-    }, 5000); 
+    }, 5000);
 
     // An abort listener allows for cleanup for a given worker
     // such that it may be resused for future tasks
@@ -23,7 +23,7 @@ function asyncAbortHandlerNeverResolves() {
   return new Promise((resolve) => {
     let timeout = setTimeout(() => {
         resolve();
-    }, 5000);
+    }, 1_000_000_000);
 
     // An abort listener allows for cleanup for a given worker
     // such that it may be resused for future tasks
@@ -36,7 +36,7 @@ function asyncAbortHandlerNeverResolves() {
           res();
           resolve();
         // set the timeout high so it will not resolve before the external
-        // timeout triggers and exits the worker 
+        // timeout triggers and exits the worker
         }, 1_000_000_000);
       });
     });
@@ -52,4 +52,4 @@ workerpool.worker(
   {
     abortListenerTimeout: 1000
   }
-);
+);