AsyncFromSyncIteratorPrototype.js [plain text]
function next(value)
{
"use strict";
var promise = @newPromise();
if (!@isObject(this) || !@isObject(@getByIdDirectPrivate(this, "syncIterator"))) {
@rejectPromiseWithFirstResolvingFunctionCallCheck(promise, @makeTypeError('Iterator is not an object.'));
return promise;
}
var syncIterator = @getByIdDirectPrivate(this, "syncIterator");
var nextMethod = @getByIdDirectPrivate(this, "nextMethod");
try {
var nextResult = @argumentCount() === 0 ? nextMethod.@call(syncIterator) : nextMethod.@call(syncIterator, value);
var nextDone = !!nextResult.done;
var nextValue = nextResult.value;
@resolveWithoutPromise(nextValue,
function (result) { @resolvePromiseWithFirstResolvingFunctionCallCheck(promise, { value: result, done: nextDone }); },
function (error) { @rejectPromiseWithFirstResolvingFunctionCallCheck(promise, error); });
} catch (e) {
@rejectPromiseWithFirstResolvingFunctionCallCheck(promise, e);
}
return promise;
}
function return(value)
{
"use strict";
var promise = @newPromise();
if (!@isObject(this) || !@isObject(@getByIdDirectPrivate(this, "syncIterator"))) {
@rejectPromiseWithFirstResolvingFunctionCallCheck(promise, @makeTypeError('Iterator is not an object.'));
return promise;
}
var syncIterator = @getByIdDirectPrivate(this, "syncIterator");
var returnMethod;
try {
returnMethod = syncIterator.return;
} catch (e) {
@rejectPromiseWithFirstResolvingFunctionCallCheck(promise, e);
return promise;
}
if (@isUndefinedOrNull(returnMethod)) {
@resolvePromiseWithFirstResolvingFunctionCallCheck(promise, { value, done: true });
return promise;
}
try {
var returnResult = @argumentCount() === 0 ? returnMethod.@call(syncIterator) : returnMethod.@call(syncIterator, value);
if (!@isObject(returnResult)) {
@rejectPromiseWithFirstResolvingFunctionCallCheck(promise, @makeTypeError('Iterator result interface is not an object.'));
return promise;
}
var resultDone = !!returnResult.done;
var resultValue = returnResult.value;
@resolveWithoutPromise(resultValue,
function (result) { @resolvePromiseWithFirstResolvingFunctionCallCheck(promise, { value: result, done: resultDone }); },
function (error) { @rejectPromiseWithFirstResolvingFunctionCallCheck(promise, error); });
} catch (e) {
@rejectPromiseWithFirstResolvingFunctionCallCheck(promise, e);
}
return promise;
}
function throw(exception)
{
"use strict";
var promise = @newPromise();
if (!@isObject(this) || !@isObject(@getByIdDirectPrivate(this, "syncIterator"))) {
@rejectPromiseWithFirstResolvingFunctionCallCheck(promise, @makeTypeError('Iterator is not an object.'));
return promise;
}
var syncIterator = @getByIdDirectPrivate(this, "syncIterator");
var throwMethod;
try {
throwMethod = syncIterator.throw;
} catch (e) {
@rejectPromiseWithFirstResolvingFunctionCallCheck(promise, e);
return promise;
}
if (@isUndefinedOrNull(throwMethod)) {
@rejectPromiseWithFirstResolvingFunctionCallCheck(promise, exception);
return promise;
}
try {
var throwResult = @argumentCount() === 0 ? throwMethod.@call(syncIterator) : throwMethod.@call(syncIterator, exception);
if (!@isObject(throwResult)) {
@rejectPromiseWithFirstResolvingFunctionCallCheck(promise, @makeTypeError('Iterator result interface is not an object.'));
return promise;
}
var throwDone = !!throwResult.done;
var throwValue = throwResult.value;
@resolveWithoutPromise(throwValue,
function (result) { @resolvePromiseWithFirstResolvingFunctionCallCheck(promise, { value: result, done: throwDone }); },
function (error) { @rejectPromiseWithFirstResolvingFunctionCallCheck(promise, error); });
} catch (e) {
@rejectPromiseWithFirstResolvingFunctionCallCheck(promise, e);
}
return promise;
}
@globalPrivate
function createAsyncFromSyncIterator(syncIterator, nextMethod)
{
"use strict";
if (!@isObject(syncIterator))
@throwTypeError('Only objects can be wrapped by async-from-sync wrapper');
return new @AsyncFromSyncIterator(syncIterator, nextMethod);
}
@globalPrivate
@constructor
function AsyncFromSyncIterator(syncIterator, nextMethod)
{
"use strict";
@putByIdDirectPrivate(this, "syncIterator", syncIterator);
@putByIdDirectPrivate(this, "nextMethod", nextMethod);
}