/
queue_runner.js
92 lines (79 loc) · 2.23 KB
/
queue_runner.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
/**
* Copyright (c) 2014-present, Facebook, Inc. All rights reserved.
*
* This source code is licensed under the MIT license found in the
* LICENSE file in the root directory of this source tree.
*
* @flow
*/
// Try getting the real promise object from the context, if available. Someone
// could have overridden it in a test.
const Promise: Class<Promise> =
global[Symbol.for('jest-native-promise')] || global.Promise;
import PCancelable from './p_cancelable';
import pTimeout from './p_timeout';
type Options = {
clearTimeout: (timeoutID: number) => void,
fail: () => void,
onException: (error: Error) => void,
queueableFns: Array<QueueableFn>,
setTimeout: (func: () => void, delay: number) => number,
userContext: any,
};
type QueueableFn = {
fn: (next: () => void) => void,
timeout?: () => number,
};
export default function queueRunner(options: Options) {
const token = new PCancelable((onCancel, resolve) => {
onCancel(resolve);
});
const mapper = ({fn, timeout, initError = new Error()}) => {
let promise = new Promise(resolve => {
const next = function(err) {
if (err) {
options.fail.apply(null, arguments);
}
resolve();
};
next.fail = function() {
options.fail.apply(null, arguments);
resolve();
};
try {
fn.call(options.userContext, next);
} catch (e) {
options.onException(e);
resolve();
}
});
promise = Promise.race([promise, token]);
if (!timeout) {
return promise;
}
const timeoutMs: number = timeout();
return pTimeout(
promise,
timeoutMs,
options.clearTimeout,
options.setTimeout,
() => {
initError.message =
'Timeout - Async callback was not invoked within the ' +
timeoutMs +
'ms 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),
};
}