feat: add mutex to in band runner (#7)

* feat: add mutex to in band runner

* Update CHANGELOG.md

Author: SimenB

CHANGELOG.md

@@ -1,5 +1,8 @@
 ## master
 
+### Fixes
+* Use a mutex when running in band as well ([#7](https://github.com/rogeliog/create-jest-runner/pull/7))
+
 ## 0.3.0
 
 ### Fixes
@@ -20,4 +23,4 @@
 
 ## 0.1.0
 
-* Initial Release
+* Initial Release

lib/createJestRunner.js

@@ -42,36 +42,39 @@ const createRunner = runPath => {
       onFailure,
       options,
     ) {
+      const mutex = throat(1);
       return tests.reduce(
         (promise, test) =>
-          promise
-            .then(() => {
-              if (watcher.isInterrupted()) {
-                throw new CancelRun();
-              }
-
-              return onStart(test).then(() => {
-                // eslint-disable-next-line import/no-dynamic-require, global-require
-                const runner = require(runPath);
-                const baseOptions = {
-                  config: test.context.config,
-                  globalConfig: this._globalConfig,
-                  testPath: test.path,
-                  rawModuleMap: watcher.isWatchMode()
-                    ? test.context.moduleMap.getRawModuleMap()
-                    : null,
-                  options,
-                };
-
-                if (typeof runner.default === 'function') {
-                  return runner.default(baseOptions);
+          mutex(() =>
+            promise
+              .then(() => {
+                if (watcher.isInterrupted()) {
+                  throw new CancelRun();
                 }
 
-                return runner(baseOptions);
-              });
-            })
-            .then(result => onResult(test, result))
-            .catch(err => onFailure(test, err)),
+                return onStart(test).then(() => {
+                  // eslint-disable-next-line import/no-dynamic-require, global-require
+                  const runner = require(runPath);
+                  const baseOptions = {
+                    config: test.context.config,
+                    globalConfig: this._globalConfig,
+                    testPath: test.path,
+                    rawModuleMap: watcher.isWatchMode()
+                      ? test.context.moduleMap.getRawModuleMap()
+                      : null,
+                    options,
+                  };
+
+                  if (typeof runner.default === 'function') {
+                    return runner.default(baseOptions);
+                  }
+
+                  return runner(baseOptions);
+                });
+              })
+              .then(result => onResult(test, result))
+              .catch(err => onFailure(test, err)),
+          ),
         Promise.resolve(),
       );
     }