2 // https://github.com/tc39/proposal-iterator-helpers
3 var $ = require('../internals/export');
4 var global = require('../internals/global');
5 var call = require('../internals/function-call');
6 var aCallable = require('../internals/a-callable');
7 var anObject = require('../internals/an-object');
8 var getBuiltIn = require('../internals/get-built-in');
10 var Promise = getBuiltIn('Promise');
11 var TypeError = global.TypeError;
13 $({ target: 'AsyncIterator', proto: true, real: true }, {
14 reduce: function reduce(reducer /* , initialValue */) {
15 var iterator = anObject(this);
16 var next = aCallable(iterator.next);
17 var noInitial = arguments.length < 2;
18 var accumulator = noInitial ? undefined : arguments[1];
21 return new Promise(function (resolve, reject) {
22 var loop = function () {
24 Promise.resolve(anObject(call(next, iterator))).then(function (step) {
26 if (anObject(step).done) {
27 noInitial ? reject(TypeError('Reduce of empty iterator with no initial value')) : resolve(accumulator);
29 var value = step.value;
35 Promise.resolve(reducer(accumulator, value)).then(function (result) {
41 } catch (err) { reject(err); }
43 } catch (error) { reject(error); }