Source code
Revision control
Copy as Markdown
Other Tools
// |reftest| skip-if(!xulRuntime.shell) -- needs drainJobQueue
var BUGNUMBER = 1180306;
var summary = 'Promise.{all,race} should close iterator on error';
print(BUGNUMBER + ": " + summary);
function test(ctor, props, { nextVal=undefined,
nextThrowVal=undefined,
modifier=undefined,
rejectReason=undefined,
rejectType=undefined,
closed=true }) {
function getIterable() {
let iterable = {
closed: false,
[Symbol.iterator]() {
let iterator = {
first: true,
next() {
if (this.first) {
this.first = false;
if (nextThrowVal)
throw nextThrowVal;
return nextVal;
}
return { value: undefined, done: true };
},
return() {
iterable.closed = true;
return {};
}
};
if (modifier)
modifier(iterator, iterable);
return iterator;
}
};
return iterable;
}
for (let prop of props) {
let iterable = getIterable();
let e;
ctor[prop](iterable).catch(e_ => { e = e_; });
drainJobQueue();
if(rejectType)
assertEq(e instanceof rejectType, true);
else
assertEq(e, rejectReason);
assertEq(iterable.closed, closed);
}
}
// == Error cases with close ==
// ES 2017 draft 25.4.4.1.1 step 6.i.
// ES 2017 draft 25.4.4.3.1 step 3.h.
class MyPromiseStaticResolveGetterThrows extends Promise {
static get resolve() {
throw "static resolve getter throws";
}
};
test(MyPromiseStaticResolveGetterThrows, ["all", "race"], {
nextVal: { value: Promise.resolve(1), done: false },
rejectReason: "static resolve getter throws",
closed: false,
});
class MyPromiseStaticResolveThrows extends Promise {
static resolve() {
throw "static resolve throws";
}
};
test(MyPromiseStaticResolveThrows, ["all", "race"], {
nextVal: { value: Promise.resolve(1), done: false },
rejectReason: "static resolve throws",
closed: true,
});
// ES 2017 draft 25.4.4.1.1 step 6.q.
// ES 2017 draft 25.4.4.3.1 step 3.i.
class MyPromiseThenGetterThrows extends Promise {
static resolve() {
return {
get then() {
throw "then getter throws";
}
};
}
};
test(MyPromiseThenGetterThrows, ["all", "race"], {
nextVal: { value: Promise.resolve(1), done: false },
rejectReason: "then getter throws",
closed: true,
});
class MyPromiseThenThrows extends Promise {
static resolve() {
return {
then() {
throw "then throws";
}
};
}
};
test(MyPromiseThenThrows, ["all", "race"], {
nextVal: { value: Promise.resolve(1), done: false },
rejectReason: "then throws",
closed: true,
});
// ES 2017 draft 7.4.6 step 3.
// if GetMethod fails, the thrown value should be used.
test(MyPromiseThenThrows, ["all", "race"], {
nextVal: { value: Promise.resolve(1), done: false },
modifier: (iterator, iterable) => {
Object.defineProperty(iterator, "return", {
get: function() {
iterable.closed = true;
throw "return getter throws";
}
});
},
rejectReason: "return getter throws",
closed: true,
});
test(MyPromiseThenThrows, ["all", "race"], {
nextVal: { value: Promise.resolve(1), done: false },
modifier: (iterator, iterable) => {
Object.defineProperty(iterator, "return", {
get: function() {
iterable.closed = true;
return "non object";
}
});
},
rejectType: TypeError,
closed: true,
});
test(MyPromiseThenThrows, ["all", "race"], {
nextVal: { value: Promise.resolve(1), done: false },
modifier: (iterator, iterable) => {
Object.defineProperty(iterator, "return", {
get: function() {
iterable.closed = true;
// Non callable.
return {};
}
});
},
rejectType: TypeError,
closed: true,
});
// ES 2017 draft 7.4.6 steps 6.
// if return method throws, the thrown value should be ignored.
test(MyPromiseThenThrows, ["all", "race"], {
nextVal: { value: Promise.resolve(1), done: false },
modifier: (iterator, iterable) => {
iterator.return = function() {
iterable.closed = true;
throw "return throws";
};
},
rejectReason: "then throws",
closed: true,
});
test(MyPromiseThenThrows, ["all", "race"], {
nextVal: { value: Promise.resolve(1), done: false },
modifier: (iterator, iterable) => {
iterator.return = function() {
iterable.closed = true;
return "non object";
};
},
rejectReason: "then throws",
closed: true,
});
// == Error cases without close ==
// ES 2017 draft 25.4.4.1.1 step 6.a.
test(Promise, ["all", "race"], {
nextThrowVal: "next throws",
rejectReason: "next throws",
closed: false,
});
test(Promise, ["all", "race"], {
nextVal: { value: {}, get done() { throw "done getter throws"; } },
rejectReason: "done getter throws",
closed: false,
});
// ES 2017 draft 25.4.4.1.1 step 6.e.
test(Promise, ["all", "race"], {
nextVal: { get value() { throw "value getter throws"; }, done: false },
rejectReason: "value getter throws",
closed: false,
});
// ES 2017 draft 25.4.4.1.1 step 6.d.iii.2.
let first = true;
class MyPromiseResolveThrows extends Promise {
constructor(executer) {
if (first) {
first = false;
super((resolve, reject) => {
executer(() => {
throw "resolve throws";
}, reject);
});
return;
}
super(executer);
}
};
test(MyPromiseResolveThrows, ["all"], {
nextVal: { value: undefined, done: true },
rejectReason: "resolve throws",
closed: false,
});
// == Successful cases ==
test(Promise, ["all", "race"], {
nextVal: { value: Promise.resolve(1), done: false },
closed: false,
});
if (typeof reportCompare === 'function')
reportCompare(true, true);