-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathindex.js
40 lines (33 loc) · 910 Bytes
/
index.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
'use strict'
function await_async (fn) {
if (typeof fn !== 'function' && fn.constructor.name !== 'GeneratorFunction') {
throw new Error('The given function must be a generator function')
}
return () => {
let args = Array.from(arguments)
return new Promise((resolve, reject) => {
const generator = fn.call(this, args)
let next = (err, value) => {
let state = null
try {
if (err) {
state = generator.throw(err)
} else {
state = generator.next(value)
}
} catch (err) {
state = { value: Promise.reject(err), done: true }
}
if (state.done) {
resolve(state.value)
return
}
Promise.resolve(state.value)
.then(res => next(null, res))
.catch(err => next(err))
}
next()
})
}
}
module.exports = await_async