Function fxAsyncGeneratorStep

xs/sources/xsGenerator.c:1670–1775

}

void fxAsyncGeneratorStep(txMachine* the, txSlot* generator, txFlag status)
{
	txSlot* stack = generator->next;
	txSlot* state = stack->next;
	txSlot* queue = state->next;
	txSlot* resolveAwaitFunction = queue->next;
	txSlot* rejectAwaitFunction = resolveAwaitFunction->next;
	txSlot* resolveYieldFunction = rejectAwaitFunction->next;
	txSlot* rejectYieldFunction = resolveYieldFunction->next;
	txSlot* resolveFunction;
	txSlot* rejectFunction;
	txSlot* value;
	
	mxTry(the) {
		if (state->value.integer == XS_CODE_END) {
			mxPush(the->scratch);
			value = the->stack;
			mxTemporary(resolveFunction);
			mxTemporary(rejectFunction);
			mxPush(mxPromiseConstructor);
			fxNewPromiseCapability(the, resolveFunction, rejectFunction);
            fxPromiseThen(the, the->stack->value.reference, resolveYieldFunction, rejectYieldFunction, C_NULL, C_NULL);
			/* THIS */
			mxPushUndefined();
			/* FUNCTION */
			if (status == XS_THROW_STATUS)
				mxPushSlot(rejectFunction);
			else
				mxPushSlot(resolveFunction);
			mxCall();
			/* ARGUMENTS */
			mxPushSlot(value);
			mxRunCount(1);
			mxPop();
		}
		else {
			the->status = status;
			status = XS_NO_STATUS;
			state->value.integer = XS_NO_CODE;
			fxRunID(the, generator, XS_NO_ID);
			if (state->value.integer == XS_NO_CODE)
				state->value.integer = XS_CODE_END;
			value = the->stack;
			if (state->value.integer == XS_CODE_END) {
				txSlot* current = queue->value.list.first;
				if (current) {
					if (value->kind == XS_UNINITIALIZED_KIND)
						value->kind = XS_UNDEFINED_KIND;
					mxPushUndefined();
					if (status == XS_THROW_STATUS)
						mxPushSlot(rejectYieldFunction);
					else
						mxPushSlot(resolveYieldFunction);
					mxCall();
					mxPushSlot(value);
					mxRunCount(1);
					mxPop();
				}