Function fx_Array_fromAsync_onIterated

xs/sources/xsArray.c:1416–1479

}

void fx_Array_fromAsync_onIterated(txMachine* the)
{
	txSlot* slot = mxFunctionInstanceHome(mxFunction->value.reference);
	txSlot* closure = slot->value.home.object;
	txSlot* resolveFunction = closure->next;
    txSlot* rejectFunction = resolveFunction->next;
    txSlot* onIteratedFunction = rejectFunction->next;
    txSlot* onRejectedFunction = onIteratedFunction->next;
    txSlot* result = onRejectedFunction->next;
    txSlot* index = result->next;
    txSlot* iterator = index->next;
    txSlot* mapFunction = iterator->next;
    txSlot* mapThis = mapFunction->next;
    txSlot* onMappedFunction = mapThis->next;

	mxTry(the) {
		mxPushSlot(mxArgv(0));
		mxGetID(mxID(_done));
		if (fxToBoolean(the, the->stack)) {
			mxPushSlot(index);
			mxPushSlot(result);
			mxSetID(mxID(_length));
			mxPop();		
			
			mxPushUndefined();
			mxPushSlot(resolveFunction);
			mxCall();
			mxPushSlot(result);
			mxRunCount(1);
			mxPop();
			return;
		}
		if (!mxIsUndefined(mapFunction)) {
			mxPushUndefined();
			mxPush(mxPromiseConstructor);
		
			mxPushSlot(mapThis);
			mxPushSlot(mapFunction);
			mxCall();
			mxPushSlot(mxArgv(0));
			mxGetID(mxID(_value));
			mxPushSlot(index);
			mxRunCount(2);
			
			fx_Promise_resolveAux(the);
			mxPop();
			mxPop();
			fxPromiseThen(the, the->stack->value.reference, onMappedFunction, onRejectedFunction, C_NULL, rejectFunction);
		}
		else {
			mxPushSlot(mxArgv(0));
			mxGetID(mxID(_value));
			mxPushSlot(result);
			mxDefineIndex(index->value.integer, 0, XS_GET_ONLY);
			mxPop();
			index->value.integer++;
			fx_Array_fromAsync_aux(the, closure);
		}