init.

Author: odeadglaz

src/hooks/spec.js

@@ -152,11 +152,11 @@ describe('Context / Hooks', () => {
             it('Triggers parent cleanup when all child process died', (done) => {
                 children.forEach(destroy);
 
-                process.nextTick(() => {
+                setTimeout(() => {
                     expect(executionMap.size).toEqual(0);
 
                     done();
-                });
+                }, 200)
             });
         });
     });

src/index.js

@@ -105,6 +105,19 @@ const createExecutionContext = () => {
 
                 fn();
             });
+        },
+
+        /**
+         * Monitors current execution map usage
+         * @return {ExecutionMapUsage}
+         */
+        monitor: () => {
+            console.log('Minotir runnig');
+
+            return {
+                size: executionContextMap.size,
+                entries: [...executionContextMap.values()]
+            }
         }
     };
 

src/types.d.ts

@@ -31,6 +31,16 @@ interface HookCallbacks {
     destroy?(asyncId: number): void;
 }
 
+interface ExecutionMapUsageEntry {
+    asyncId: number;
+    type: string;
+}
+
+interface ExecutionMapUsage {
+    size: number;
+    entries: ExecutionMapUsageEntry[];
+}
+
 interface ExecutionContextAPI {
 
     /**
@@ -48,12 +58,17 @@ interface ExecutionContextAPI {
     /**
      * Gets the current async process execution context.
      */
-    get(): object
+    get(): object;
 
     /**
      * Runs a given function within an async resource context
      * @param fn
      * @param initialContext
      */
-    run(fn: Function, initialContext: object): void
+    run(fn: Function, initialContext: object): void;
+
+    /**
+     * Monitors the current execution map usage
+     */
+    monitor(): ExecutionMapUsage;
 }