2 var call = require('../internals/function-call');
3 var aCallable = require('../internals/a-callable');
4 var anObject = require('../internals/an-object');
5 var create = require('../internals/object-create');
6 var createNonEnumerableProperty = require('../internals/create-non-enumerable-property');
7 var redefineAll = require('../internals/redefine-all');
8 var wellKnownSymbol = require('../internals/well-known-symbol');
9 var InternalStateModule = require('../internals/internal-state');
10 var getBuiltIn = require('../internals/get-built-in');
11 var getMethod = require('../internals/get-method');
12 var AsyncIteratorPrototype = require('../internals/async-iterator-prototype');
14 var Promise = getBuiltIn('Promise');
16 var setInternalState = InternalStateModule.set;
17 var getInternalState = InternalStateModule.get;
19 var TO_STRING_TAG = wellKnownSymbol('toStringTag');
21 module.exports = function (nextHandler, IS_ITERATOR) {
22 var AsyncIteratorProxy = function AsyncIterator(state) {
23 state.next = aCallable(state.iterator.next);
25 state.ignoreArgument = !IS_ITERATOR;
26 setInternalState(this, state);
29 AsyncIteratorProxy.prototype = redefineAll(create(AsyncIteratorPrototype), {
30 next: function next(arg) {
32 var hasArgument = !!arguments.length;
33 return new Promise(function (resolve) {
34 var state = getInternalState(that);
35 var args = hasArgument ? [state.ignoreArgument ? undefined : arg] : IS_ITERATOR ? [] : [undefined];
36 state.ignoreArgument = false;
37 resolve(state.done ? { done: true, value: undefined } : anObject(call(nextHandler, state, Promise, args)));
40 'return': function (value) {
42 return new Promise(function (resolve, reject) {
43 var state = getInternalState(that);
44 var iterator = state.iterator;
46 var $$return = getMethod(iterator, 'return');
47 if ($$return === undefined) return resolve({ done: true, value: value });
48 Promise.resolve(call($$return, iterator, value)).then(function (result) {
50 resolve({ done: true, value: value });
54 'throw': function (value) {
56 return new Promise(function (resolve, reject) {
57 var state = getInternalState(that);
58 var iterator = state.iterator;
60 var $$throw = getMethod(iterator, 'throw');
61 if ($$throw === undefined) return reject(value);
62 resolve(call($$throw, iterator, value));
68 createNonEnumerableProperty(AsyncIteratorProxy.prototype, TO_STRING_TAG, 'Generator');
71 return AsyncIteratorProxy;