Function fxStepAsync

xs/sources/xsFunction.c:663–724

}

void fxStepAsync(txMachine* the, txSlot* instance, txFlag status)
{
	txSlot* state = instance->next->next;
	txSlot* promise = state->next;
	txSlot* resolveFunction = promise->next;
	txSlot* rejectFunction = resolveFunction->next;
	txSlot* resolveAwaitFunction = rejectFunction->next;
	txSlot* rejectAwaitFunction = resolveAwaitFunction->next;
	txSlot* value;
	mxTry(the) {
		the->status = status;
		state->value.integer = XS_NO_CODE;
		fxRunID(the, instance, XS_NO_ID);
		value = the->stack;
		if (state->value.integer == XS_NO_CODE) {
			/* THIS */
			mxPushUndefined();
			/* FUNCTION */
			mxPushSlot(resolveFunction);
			mxCall();
			/* ARGUMENTS */
			mxPushSlot(value);
			mxRunCount(1);
			mxPop();
		}
		else {
			if (mxIsReference(value) && mxIsPromise(value->value.reference)) {
				mxDub();
				mxGetID(mxID(_constructor));
				if (fxIsSameValue(the, &mxPromiseConstructor, the->stack, 0)) {
					mxPop();
					fxPromiseThen(the, value->value.reference, resolveAwaitFunction, rejectAwaitFunction, C_NULL, C_NULL);
					goto exit;
				}
				mxPop();
			}
			mxTemporary(resolveFunction);
			mxTemporary(rejectFunction);
			mxPush(mxPromiseConstructor);
			fxNewPromiseCapability(the, resolveFunction, rejectFunction);
#ifdef mxPromisePrint
			fprintf(stderr, "fxStepAsync %d\n", the->stack->value.reference->next->ID);
#endif
			fxPromiseThen(the, the->stack->value.reference, resolveAwaitFunction, rejectAwaitFunction, C_NULL, C_NULL);
			/* THIS */
			mxPushUndefined();
			/* FUNCTION */
			mxPushSlot(resolveFunction);
			mxCall();
			/* ARGUMENTS */
			mxPushSlot(value);
			/* COUNT */
			mxRunCount(1);
			mxPop();
		}
exit:			
		mxPop();
	}