fix(overmind): fix async detection of operators

Author: christianalfoni

packages/node_modules/overmind/src/operator.ts

@@ -128,12 +128,7 @@ export function createOperator<ThisConfig extends IConfiguration>(
 ): any {
   const operator = (err, context, next, final) => {
     operatorStarted(type, name, context)
-    let asyncTimeout = setTimeout(() => {
-      context.execution.emit(EventType.OPERATOR_ASYNC, {
-        ...context.execution,
-        isAsync: true,
-      })
-    })
+    let nextIsCalled = false
     try {
       cb(
         err,
@@ -170,12 +165,12 @@ export function createOperator<ThisConfig extends IConfiguration>(
               .then((promiseValue) => run(err, promiseValue))
               .catch((promiseError) => run(promiseError, promiseError))
           } else {
-            clearTimeout(asyncTimeout)
+            nextIsCalled = true
             run(err, value)
           }
         },
         (err, value) => {
-          clearTimeout(asyncTimeout)
+          nextIsCalled = true
           operatorStopped(context, err || value, {
             isSkipped: Boolean(err),
             isIntercepted: !err,
@@ -184,12 +179,19 @@ export function createOperator<ThisConfig extends IConfiguration>(
         }
       )
     } catch (error) {
-      clearTimeout(asyncTimeout)
+      nextIsCalled = true
       operatorStopped(context, context.value, {
         error,
       })
       next(error, createContext(context, context.value))
     }
+
+    if (!nextIsCalled) {
+      context.execution.emit(EventType.OPERATOR_ASYNC, {
+        ...context.execution,
+        isAsync: true,
+      })
+    }
   }
 
   operator[IS_OPERATOR] = true
@@ -226,12 +228,7 @@ export function createMutationOperator<ThisConfig extends IConfiguration>(
         })
       })
     }
-    let asyncTimeout = setTimeout(() => {
-      context.execution.emit(EventType.OPERATOR_ASYNC, {
-        ...context.execution,
-        isAsync: true,
-      })
-    })
+    let nextIsCalled = false
     try {
       cb(
         err,
@@ -256,12 +253,12 @@ export function createMutationOperator<ThisConfig extends IConfiguration>(
               .then((promiseValue) => run(err, promiseValue))
               .catch((promiseError) => run(promiseError, promiseError))
           } else {
-            clearTimeout(asyncTimeout)
+            nextIsCalled = true
             run(err, value)
           }
         },
         (err, value) => {
-          clearTimeout(asyncTimeout)
+          nextIsCalled = true
           operatorStopped(context, err || value, {
             isSkipped: Boolean(err),
             isIntercepted: !err,
@@ -293,12 +290,19 @@ export function createMutationOperator<ThisConfig extends IConfiguration>(
         })
       }
     } catch (error) {
-      clearTimeout(asyncTimeout)
+      nextIsCalled = true
       operatorStopped(context, context.value, {
         error,
       })
       next(error, createContext(context, context.value))
     }
+
+    if (!nextIsCalled) {
+      context.execution.emit(EventType.OPERATOR_ASYNC, {
+        ...context.execution,
+        isAsync: true,
+      })
+    }
   }
 
   operator[IS_OPERATOR] = true