Function AwaitValue

bridge.c:372–447

* quickjs-go local await helper. * * Unlike js_std_await from quickjs-libc, this keeps polling in bounded slices * and explicitly polls interrupt state directly so * execute-timeout/interrupt handlers can abort permanently pending promises. */

 * execute-timeout/interrupt handlers can abort permanently pending promises.
 */
JSValue AwaitValue(JSContext *ctx, JSValue obj) {
    JSRuntime *rt = JS_GetRuntime(ctx);

    for (;;) {
        if (ThrowUnhandledPromiseRejectionIfAny(ctx)) {
            JS_FreeValue(ctx, obj);
            return JS_EXCEPTION;
        }

        if (isExecuteTimeoutExceeded(rt)) {
            JS_FreeValue(ctx, obj);
            JS_ThrowInternalError(ctx, "interrupted");
            return JS_EXCEPTION;
        }

        int state = JS_PromiseState(ctx, obj);
        if (state == JS_PROMISE_FULFILLED) {
            JSValue ret = JS_PromiseResult(ctx, obj);
            JS_FreeValue(ctx, obj);
            return ret;
        }

        if (state == JS_PROMISE_REJECTED) {
            JSValue ret = JS_Throw(ctx, JS_PromiseResult(ctx, obj));
            JS_FreeValue(ctx, obj);
            return ret;
        }

        if (state != JS_PROMISE_PENDING) {
            return obj;
        }

        JSContext *ctx1 = NULL;
        int err = JS_ExecutePendingJob(rt, &ctx1);
        if (err < 0) {
            if (ctx1 != NULL && ctx1 != ctx) {
                JSValue ex = JS_GetException(ctx1);
                JS_Throw(ctx, ex);
            }
            JS_FreeValue(ctx, obj);
            return JS_EXCEPTION;
        }

        /* Bound host IO polling to avoid an uninterruptible blocking wait. */
        if (err == 0) {
            /*
             * Drive timers/microtasks so promises resolved by setTimeout can
             * progress while awaiting.
             */
            int loop_once_ret = js_std_loop_once(ctx);
            if (loop_once_ret == -2) {
                JS_FreeValue(ctx, obj);
                return JS_EXCEPTION;
            }
            if (loop_once_ret == 0) {
                continue;
            }