forked from wuyawei/fe-code
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathcreateFlow.js
More file actions
66 lines (60 loc) · 1.57 KB
/
Copy pathcreateFlow.js
File metadata and controls
66 lines (60 loc) · 1.57 KB
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
/*
const delay = (ms) => new Promise((resolve) => setTimeout(resolve, ms));
const subFlow = createFlow([() => delay(1000).then(() => log("c"))]);
createFlow([
() => log("a"),
() => log("b"),
subFlow,
[() => delay(1000).then(() => log("d")), () => log("e")],
]).run(() => {
console.log("done");
});
// 需要按照 a,b,延迟1秒,c,延迟1秒,d,e, done 的顺序打印
*/
var { log } = console;
const delay = (ms) => new Promise((resolve) => setTimeout(resolve, ms));
const createFlow = (arr) => {
const queue = arr.flat();
const run = async (done) => {
done && queue.push(done);
for(let i = 0; i < queue.length; i++) {
const fn = queue[i];
if (typeof fn.run === 'function') {
await fn.run();
} else {
await fn();
}
}
}
return {
run
};
};
const createFlow1 = (arr) => {
const queue = arr.flat();
const run = (done) => {
done && queue.push(done);
let p = Promise.resolve();
for(let i = 0; i < queue.length; i++) {
const fn = queue[i];
if (typeof fn.run === 'function') {
p = p.then(() => fn.run())
} else {
p = p.then(() => fn());
}
}
return p;
}
return {
run
};
};
const subFlow = createFlow([() => delay(1000).then(() => log("c"))]);
createFlow([
() => log("a"),
() => log("b"),
subFlow,
[() => delay(1000).then(() => log("d")), () => log("e")],
]).run(() => {
console.log("done");
});