-
Notifications
You must be signed in to change notification settings - Fork 0
/
async.js
71 lines (68 loc) · 1.86 KB
/
async.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
/*jshint node:true, browser:true, noyield:true */
/*globals define*/
(function() {
"use strict";
function async(func, self) {
return function asyncFunction() {
const args = Array.from(arguments);
return new Promise(function(resolve, reject) {
var gen;
if (typeof func !== "function") {
reject(new TypeError("Expected a Function."));
}
//not a generator, wrap it.
if (func.constructor.name !== "GeneratorFunction") {
gen = (function *() {
return func.call(self, ...args);
}());
} else {
gen = func.call(self, ...args);
}
try {
step(gen.next(undefined));
} catch (err) {
reject(err);
}
function step(next) {
const value = next.value;
if (next.done) {
return resolve(value);
}
if (value instanceof Promise || isThenable(value)) {
return value.then(
result => step(gen.next(result)),
error => {
try {
step(gen.throw(error));
} catch (err) {
throw err;
}
}
).catch((err) => {
reject(err);
});
}
step(gen.next(value));
}
});
};
}
function isThenable(obj) {
return obj && typeof obj === "object" && typeof obj.then === "function";
}
async.task = function(func, self) {
return async(func, self)();
};
//Export it for browser, require, and node
if (typeof module !== "undefined" && typeof module.exports !== "undefined") {
module.exports = async;
} else {
if (typeof define === "function" && define.amd) {
define([], function() {
return async;
});
} else {
window.async = async;
}
}
}).call(this);