Function fxPromiseThen

xs/sources/xsPromise.c:580–639

}

void fxPromiseThen(txMachine* the, txSlot* promise, txSlot* onFullfilled, txSlot* onRejected, txSlot* resolveFunction, txSlot* rejectFunction)
{
	txSlot* reaction;
	txSlot* slot;
	txSlot* status;
	
	reaction = fxNewInstance(the);
	slot = reaction->next = fxNewSlot(the);
	slot->flag = XS_INTERNAL_FLAG;
	if (resolveFunction) {
		slot->kind = resolveFunction->kind;
		slot->value = resolveFunction->value;
	}
	slot = slot->next = fxNewSlot(the);
	slot->flag = XS_INTERNAL_FLAG;
	if (rejectFunction) {
		slot->kind = rejectFunction->kind;
		slot->value = rejectFunction->value;
	}
	slot = slot->next = fxNewSlot(the);
	slot->ID = mxID(__onFullfilled_);
	if (onFullfilled) {
		slot->kind = onFullfilled->kind;
		slot->value = onFullfilled->value;
	}
	slot = slot->next = fxNewSlot(the);
	slot->ID = mxID(__onRejected_);
	if (onRejected) {
		slot->kind = onRejected->kind;
		slot->value = onRejected->value;
	}
	if (resolveFunction) {
		slot = slot->next = fxNewSlot(the);
		slot->ID = mxID(__result_);
		slot->kind = mxResult->kind;
		slot->value = mxResult->value;
	}
		
	status = mxPromiseStatus(promise);
	if (status->value.integer == mxPendingStatus) {
		txSlot** address = &(mxPromiseThens(promise)->value.reference->next);
		while ((slot = *address)) 
			address = &(slot->next);
		slot = *address = fxNewSlot(the);
		slot->kind = XS_REFERENCE_KIND;
		slot->value.reference = reaction;
	}
	else {
		mxPushReference(reaction);
		if (status->value.integer == mxFulfilledStatus)
			mxPush(mxOnResolvedPromiseFunction);
		else
			mxPush(mxOnRejectedPromiseFunction);
		mxCall();
		slot = mxPromiseResult(promise);
		mxPushSlot(slot);
		fxQueueJob(the, 1, promise);
	}