From cc97a4dd2a967e1c2273bd5f4c5f49a5bf2e2585 Mon Sep 17 00:00:00 2001 From: Florian Dold Date: Wed, 27 Mar 2019 21:01:33 +0100 Subject: remove node_modules --- node_modules/ava/lib/concurrent.js | 64 -------------------------------------- 1 file changed, 64 deletions(-) delete mode 100644 node_modules/ava/lib/concurrent.js (limited to 'node_modules/ava/lib/concurrent.js') 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; -- cgit v1.2.3