Hooks suspend adjusted.

ZLIB ignore.

Author: odeadglaz

src/hooks/constants.js

@@ -4,4 +4,10 @@
  * We can skip those types assuming the execution context won't be used for process types.
  * @type {Set<String>}
  */
-exports.EXCLUDED_ASYNC_TYPES  = new Set(['DNSCHANNEL', 'TLSWRAP', 'TCPWRAP', 'HTTPPARSER']);
+exports.EXCLUDED_ASYNC_TYPES  = new Set([
+    'DNSCHANNEL',
+    'TLSWRAP',
+    'TCPWRAP',
+    'HTTPPARSER',
+    'ZLIB'
+]);

src/hooks/index.js

@@ -11,13 +11,12 @@ const getContextRef = (parentContext, triggerAsyncId) => (
 );
 
 /**
- * Suspends map entry removal using next tick queue
- * @param {ExecutionContextMap} map - The execution context map
- * @param {Number} id - The async id to remove
+ * Suspends a given function execution over process next tick.
+ * @param {Function} fn - The function to trigger upon next tick.
+ * @param {...any} args - The function arguments to trigger with.
+ * @return {any}
  */
-const suspendedDelete = (map, id) => process.nextTick(
-    () => map.delete(id)
-);
+const suspend = (fn, ...args) => process.nextTick(() => fn(...args));
 
 /**
  * The "async_hooks" init hook callback, used to initialize sub process of the main context
@@ -59,7 +58,7 @@ const onChildProcessDestroy = (executionContextMap, asyncId, ref) => {
 
     // Parent context will be released upon last child removal
     if (!children.length) {
-        suspendedDelete(executionContextMap, ref);
+        executionContextMap.delete(ref)
 
         return;
     }
@@ -85,14 +84,14 @@ const destroy = (executionContextMap) => (asyncId)=> {
 
     // Child context's will unregister themselves from root context
     if (!isUndefined(ref)) {
-        onChildProcessDestroy(
+        suspend(
+            onChildProcessDestroy,
             executionContextMap,
             asyncId,
-            ref,
+            ref
         );
     }
-
-    suspendedDelete(executionContextMap, asyncId);
+    executionContextMap.delete(asyncId);
 };
 
 

src/index.js

@@ -41,6 +41,7 @@ const createExecutionContext = () => {
          * @returns void
          */
         create: (initialContext = {}) => {
+            console.log('Creating execution context : ', executionContextMap);
             const asyncId = asyncHooks.executionAsyncId();
 
             // Creation is allowed once per execution context