aboutsummaryrefslogtreecommitdiff
path: root/node_modules/ava/lib/concurrent.js
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2019-03-27 21:01:33 +0100
committerFlorian Dold <florian.dold@gmail.com>2019-03-27 21:01:33 +0100
commitcc97a4dd2a967e1c2273bd5f4c5f49a5bf2e2585 (patch)
tree92c5d88706a6ffc654d1b133618d357890e7096b /node_modules/ava/lib/concurrent.js
parent3771b4d6b67b34c130f3a9a1a15f42deefdb2eda (diff)
remove node_modules
Diffstat (limited to 'node_modules/ava/lib/concurrent.js')
-rw-r--r--node_modules/ava/lib/concurrent.js64
1 files changed, 0 insertions, 64 deletions
diff --git a/node_modules/ava/lib/concurrent.js b/node_modules/ava/lib/concurrent.js
deleted file mode 100644
index 3cdbb41c3..000000000
--- a/node_modules/ava/lib/concurrent.js
+++ /dev/null
@@ -1,64 +0,0 @@
-'use strict';
-
-class Concurrent {
- constructor(runnables, bail) {
- if (!Array.isArray(runnables)) {
- throw new TypeError('Expected an array of runnables');
- }
-
- this.runnables = runnables;
- this.bail = bail || false;
- }
-
- run() {
- let allPassed = true;
-
- let pending;
- let rejectPending;
- let resolvePending;
- const allPromises = [];
- const handlePromise = promise => {
- if (!pending) {
- pending = new Promise((resolve, reject) => {
- rejectPending = reject;
- resolvePending = resolve;
- });
- }
-
- allPromises.push(promise.then(passed => {
- if (!passed) {
- allPassed = false;
-
- if (this.bail) {
- // Stop if the test failed and bail mode is on.
- resolvePending();
- }
- }
- }, rejectPending));
- };
-
- for (const runnable of this.runnables) {
- const passedOrPromise = runnable.run();
-
- if (!passedOrPromise) {
- if (this.bail) {
- // Stop if the test failed and bail mode is on.
- return false;
- }
-
- allPassed = false;
- } else if (passedOrPromise !== true) {
- handlePromise(passedOrPromise);
- }
- }
-
- if (pending) {
- Promise.all(allPromises).then(resolvePending);
- return pending.then(() => allPassed);
- }
-
- return allPassed;
- }
-}
-
-module.exports = Concurrent;