aboutsummaryrefslogtreecommitdiff
path: root/node_modules/jest-jasmine2/build/queueRunner.js
diff options
context:
space:
mode:
authorJoel Kronqvist <joel.h.kronqvist@gmail.com>2022-03-05 19:02:27 +0200
committerJoel Kronqvist <joel.h.kronqvist@gmail.com>2022-03-05 19:02:27 +0200
commit5d309ff52cd399a6b71968a6b9a70c8ac0b98981 (patch)
tree360f7eb50f956e2367ef38fa1fc6ac7ac5258042 /node_modules/jest-jasmine2/build/queueRunner.js
parentb500a50f1b97d93c98b36ed9a980f8188d648147 (diff)
downloadLYLLRuoka-5d309ff52cd399a6b71968a6b9a70c8ac0b98981.tar.gz
LYLLRuoka-5d309ff52cd399a6b71968a6b9a70c8ac0b98981.zip
Added node_modules for the updating to work properly.
Diffstat (limited to 'node_modules/jest-jasmine2/build/queueRunner.js')
-rw-r--r--node_modules/jest-jasmine2/build/queueRunner.js127
1 files changed, 127 insertions, 0 deletions
diff --git a/node_modules/jest-jasmine2/build/queueRunner.js b/node_modules/jest-jasmine2/build/queueRunner.js
new file mode 100644
index 0000000..1580255
--- /dev/null
+++ b/node_modules/jest-jasmine2/build/queueRunner.js
@@ -0,0 +1,127 @@
+'use strict';
+
+Object.defineProperty(exports, '__esModule', {
+ value: true
+});
+exports.default = queueRunner;
+
+var _jestUtil = require('jest-util');
+
+var _PCancelable = _interopRequireDefault(require('./PCancelable'));
+
+var _pTimeout = _interopRequireDefault(require('./pTimeout'));
+
+function _interopRequireDefault(obj) {
+ return obj && obj.__esModule ? obj : {default: obj};
+}
+
+var global = (function () {
+ if (typeof globalThis !== 'undefined') {
+ return globalThis;
+ } else if (typeof global !== 'undefined') {
+ return global;
+ } else if (typeof self !== 'undefined') {
+ return self;
+ } else if (typeof window !== 'undefined') {
+ return window;
+ } else {
+ return Function('return this')();
+ }
+})();
+
+var Symbol = global['jest-symbol-do-not-touch'] || global.Symbol;
+
+var global = (function () {
+ if (typeof globalThis !== 'undefined') {
+ return globalThis;
+ } else if (typeof global !== 'undefined') {
+ return global;
+ } else if (typeof self !== 'undefined') {
+ return self;
+ } else if (typeof window !== 'undefined') {
+ return window;
+ } else {
+ return Function('return this')();
+ }
+})();
+
+var Symbol = global['jest-symbol-do-not-touch'] || global.Symbol;
+
+var global = (function () {
+ if (typeof globalThis !== 'undefined') {
+ return globalThis;
+ } else if (typeof global !== 'undefined') {
+ return global;
+ } else if (typeof self !== 'undefined') {
+ return self;
+ } else if (typeof window !== 'undefined') {
+ return window;
+ } else {
+ return Function('return this')();
+ }
+})();
+
+var Promise = global[Symbol.for('jest-native-promise')] || global.Promise;
+
+function queueRunner(options) {
+ const token = new _PCancelable.default((onCancel, resolve) => {
+ onCancel(resolve);
+ });
+
+ const mapper = ({fn, timeout, initError = new Error()}) => {
+ let promise = new Promise(resolve => {
+ const next = function (...args) {
+ const err = args[0];
+
+ if (err) {
+ options.fail.apply(null, args);
+ }
+
+ resolve();
+ };
+
+ next.fail = function (...args) {
+ options.fail.apply(null, args);
+ resolve();
+ };
+
+ try {
+ fn.call(options.userContext, next);
+ } catch (e) {
+ options.onException(e);
+ resolve();
+ }
+ });
+ promise = Promise.race([promise, token]);
+
+ if (!timeout) {
+ return promise;
+ }
+
+ const timeoutMs = timeout();
+ return (0, _pTimeout.default)(
+ promise,
+ timeoutMs,
+ options.clearTimeout,
+ options.setTimeout,
+ () => {
+ initError.message =
+ 'Timeout - Async callback was not invoked within the ' +
+ (0, _jestUtil.formatTime)(timeoutMs) +
+ ' timeout specified by jest.setTimeout.';
+ initError.stack = initError.message + initError.stack;
+ options.onException(initError);
+ }
+ );
+ };
+
+ const result = options.queueableFns.reduce(
+ (promise, fn) => promise.then(() => mapper(fn)),
+ Promise.resolve()
+ );
+ return {
+ cancel: token.cancel.bind(token),
+ catch: result.catch.bind(result),
+ then: result.then.bind(result)
+ };
+}