async watcher

jestjs · Jul 28, 2020 · 40d7e1b · 40d7e1b
1 parent ae3b43c
commit 40d7e1b
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 10 deletions.
diff --git a/packages/jest-core/src/TestScheduler.ts b/packages/jest-core/src/TestScheduler.ts
@@ -367,15 +367,15 @@ export default class TestScheduler {
       aggregatedResults.numFailedTests >= this._globalConfig.bail
     ) {
       if (watcher.isWatchMode()) {
-        watcher.setState({interrupted: true});
-      } else {
-        const failureExit = () => exit(1);
-
-        return this._dispatcher
-          .onRunComplete(contexts, aggregatedResults)
-          .then(failureExit)
-          .catch(failureExit);
+        return watcher.setState({interrupted: true});
       }
+
+      const failureExit = () => exit(1);
+
+      return this._dispatcher
+        .onRunComplete(contexts, aggregatedResults)
+        .then(failureExit)
+        .catch(failureExit);
     }
     return Promise.resolve();
   }

diff --git a/packages/jest-core/src/TestWatcher.ts b/packages/jest-core/src/TestWatcher.ts
@@ -21,9 +21,9 @@ export default class TestWatcher extends emittery.Typed<{change: State}> {
     this._isWatchMode = isWatchMode;
   }
 
-  setState(state: State): void {
+  async setState(state: State): Promise<void> {
     Object.assign(this.state, state);
-    this.emit('change', this.state);
+    await this.emit('change', this.state);
   }
 
   isInterrupted(): boolean {