diff options
author | Joel Kronqvist <joel.h.kronqvist@gmail.com> | 2022-03-05 19:02:27 +0200 |
---|---|---|
committer | Joel Kronqvist <joel.h.kronqvist@gmail.com> | 2022-03-05 19:02:27 +0200 |
commit | 5d309ff52cd399a6b71968a6b9a70c8ac0b98981 (patch) | |
tree | 360f7eb50f956e2367ef38fa1fc6ac7ac5258042 /node_modules/jest-jasmine2/build/queueRunner.js | |
parent | b500a50f1b97d93c98b36ed9a980f8188d648147 (diff) | |
download | LYLLRuoka-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.js | 127 |
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) + }; +} |