Function fxRunPromiseJobs

xs/sources/xsPromise.c:1274–1305

}

void fxRunPromiseJobs(txMachine* the)
{
	txSlot* job;
	txSlot* slot;
	txInteger count;
	
#ifdef mxPromisePrint
	fprintf(stderr, "\n# fxRunPromiseJobs\n");
#endif
	job = mxRunningJobs.value.reference->next = mxPendingJobs.value.reference->next;
	mxPendingJobs.value.reference->next = C_NULL;
	while (job) {
		mxTry(the) {
			count = 0;
			slot = job->value.reference->next;
			while (slot) {
				mxPushSlot(slot);
				count++;
				slot = slot->next;
			}
			mxRunCount(count - 4);
			mxPop();
			if (mxDuringJobs.kind == XS_REFERENCE_KIND)
				mxDuringJobs.value.reference->next = C_NULL;
		}
		mxCatch(the) {
			fxAbort(the, XS_UNHANDLED_EXCEPTION_EXIT);
		}
		job = job->next;
	}
	mxRunningJobs.value.reference->next = C_NULL;
}