|
1 | 1 | 'use strict'; |
2 | 2 | var bind = require('../internals/function-bind-context'); |
3 | 3 | var uncurryThis = require('../internals/function-uncurry-this'); |
4 | | -var toObject = require('../internals/to-object'); |
5 | 4 | var isConstructor = require('../internals/is-constructor'); |
6 | 5 | var getAsyncIterator = require('../internals/get-async-iterator'); |
7 | 6 | var getIterator = require('../internals/get-iterator'); |
@@ -32,20 +31,19 @@ SafeArrayIterator.prototype.next = function () { |
32 | 31 |
|
33 | 32 | // `Array.fromAsync` method implementation |
34 | 33 | // https://github.com/tc39/proposal-array-from-async |
35 | | -module.exports = function fromAsync(asyncItems /* , mapfn = undefined, thisArg = undefined */) { |
| 34 | +module.exports = function fromAsync(items /* , mapfn = undefined, thisArg = undefined */) { |
36 | 35 | var C = this; |
37 | 36 | var argumentsLength = arguments.length; |
38 | 37 | var mapfn = argumentsLength > 1 ? arguments[1] : undefined; |
39 | 38 | var thisArg = argumentsLength > 2 ? arguments[2] : undefined; |
40 | 39 | return new (getBuiltIn('Promise'))(function (resolve) { |
41 | | - var O = toObject(asyncItems); |
42 | 40 | if (mapfn !== undefined) mapfn = bind(mapfn, thisArg); |
43 | | - var usingAsyncIterator = getMethod(O, ASYNC_ITERATOR); |
44 | | - var usingSyncIterator = usingAsyncIterator ? undefined : getIteratorMethod(O) || safeArrayIterator; |
| 41 | + var usingAsyncIterator = getMethod(items, ASYNC_ITERATOR); |
| 42 | + var usingSyncIterator = usingAsyncIterator ? undefined : getIteratorMethod(items) || safeArrayIterator; |
45 | 43 | var A = isConstructor(C) ? new C() : []; |
46 | 44 | var iterator = usingAsyncIterator |
47 | | - ? getAsyncIterator(O, usingAsyncIterator) |
48 | | - : new AsyncFromSyncIterator(getIteratorDirect(getIterator(O, usingSyncIterator))); |
| 45 | + ? getAsyncIterator(items, usingAsyncIterator) |
| 46 | + : new AsyncFromSyncIterator(getIteratorDirect(getIterator(items, usingSyncIterator))); |
49 | 47 | resolve(toArray(iterator, mapfn, A)); |
50 | 48 | }); |
51 | 49 | }; |
0 commit comments