Function fxCombinePromises

xs/sources/xsPromise.c:278–401

}

void fxCombinePromises(txMachine* the, txInteger which)
{
	txSlot* stack = the->stack;
	txSlot* resolveFunction;
	txSlot* rejectFunction;
	txSlot* promise;
	txSlot* object;
	txSlot* property;
	txSlot* array;
	txSlot* already;
	txSlot* iterator;
	txSlot* next;
	txSlot* value;
	txInteger index;
	
	if (!mxIsReference(mxThis))
		mxTypeError("this: not an object");
	mxTemporary(resolveFunction);
	mxTemporary(rejectFunction);
	mxPushSlot(mxThis);
	promise = fxNewPromiseCapability(the, resolveFunction, rejectFunction);
	mxPullSlot(mxResult);
	{
		mxTry(the) {
			txSlot* resolve = C_NULL;
			if (which) {
				object = fxNewInstance(the);
				property = fxNextIntegerProperty(the, object, 0, XS_NO_ID, XS_NO_FLAG);
				property = fxNextReferenceProperty(the, property, promise, XS_NO_ID, XS_NO_FLAG);
				if (which == XS_PROMISE_COMBINE_REJECTED)
					property = fxNextSlotProperty(the, property, rejectFunction, XS_NO_ID, XS_NO_FLAG);
				else
					property = fxNextSlotProperty(the, property, resolveFunction, XS_NO_ID, XS_NO_FLAG);
				mxPush(mxArrayPrototype);
				array = fxNewArrayInstance(the);
				already = array->next;
				property = fxNextReferenceProperty(the, property, array, XS_NO_ID, XS_NO_FLAG);
				mxPop();
			}
			mxPushSlot(mxThis);
			mxGetID(mxID(_resolve));	
			resolve = the->stack;
			if (!fxIsCallable(the, resolve))
				mxTypeError("resolve: not a function");
			mxTemporary(iterator);
			mxTemporary(next);
			fxGetIterator(the, mxArgv(0), iterator, next, 0);
			index = 0;
			mxTemporary(value);
			while (fxIteratorNext(the, iterator, next, value)) {
				mxTry(the) {
					mxPushSlot(mxThis);
					mxPushSlot(resolve);
					mxCall();
					mxPushSlot(value);
					mxRunCount(1);
					mxDub();
					mxGetID(mxID(_then));