summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexander Early <alexander.early@gmail.com>2018-08-05 16:42:49 -0700
committerAlexander Early <alexander.early@gmail.com>2018-08-05 16:42:49 -0700
commit309dae64a3859fc31521e38aaf041f3eee33e126 (patch)
tree2b9f5eb74241558c8e856636a214b7dd04e281c7
parent0d0c6d1a8b9ab6efe9c14d58c52ca225a67820bd (diff)
downloadasync-309dae64a3859fc31521e38aaf041f3eee33e126.tar.gz
dont pretend they're AsyncFunctions
-rw-r--r--lib/internal/awaitify.js4
-rw-r--r--test/es2017/awaitableFunctions.js14
2 files changed, 7 insertions, 11 deletions
diff --git a/lib/internal/awaitify.js b/lib/internal/awaitify.js
index eeda0e1..a65bbcb 100644
--- a/lib/internal/awaitify.js
+++ b/lib/internal/awaitify.js
@@ -1,5 +1,3 @@
-export const ASYNC_FN = Symbol('asyncFunction')
-
// conditionally promisify a function.
// only return a promise if a callback is omitted
export default function awaitify (asyncFn, arity) {
@@ -17,8 +15,6 @@ export default function awaitify (asyncFn, arity) {
})
}
- awaitable[Symbol.toStringTag] = 'AsyncFunction'
- awaitable[ASYNC_FN] = true
awaitable.displayName = `awaitable(${asyncFn.name})`
return awaitable
diff --git a/test/es2017/awaitableFunctions.js b/test/es2017/awaitableFunctions.js
index ce36867..82c489f 100644
--- a/test/es2017/awaitableFunctions.js
+++ b/test/es2017/awaitableFunctions.js
@@ -1,6 +1,6 @@
var async = require('../../lib');
const {expect} = require('chai');
-const assert = require('assert');
+const {default: wrapAsync} = require('../../lib/internal/wrapAsync')
module.exports = function () {
@@ -12,12 +12,12 @@ module.exports = function () {
const input = [1, 2, 3];
const inputObj = {a: 1, b: 2, c: 3};
- it('should asyncify async functions', (done) => {
- async.asyncify(asyncIdentity)(42, (err, val) => {
- assert(val === 42);
- done(err);
- })
- });
+ it('asyncify should not add an additional level of wrapping', () => {
+ const wrapped = wrapAsync(async.each)
+ let sameStack = false
+ wrapped([1], (val, cb) => cb(), () => {sameStack = true})
+ expect(sameStack).to.equal(true)
+ })
/*