Method run

src/platforms/shared/coroutine_context.cpp.hpp:220–263

}

void CoroutineRunner::run(fl::u32 us) FL_NOEXCEPT {
    if (mCount == 0) return;

    auto& platform = ICoroutinePlatform::instance();
    fl::u32 start = platform.micros();

    // Run at least one coroutine, then keep going until time budget exhausted
    bool first = true;
    while (first || (platform.micros() - start) < us) {
        first = false;

        if (mCount == 0) break;

        // Pick next coroutine (round-robin)
        if (mNextIndex >= mCount) {
            mNextIndex = 0;
        }

        CoroutineContext* ctx = mQueue[mNextIndex];
        ++mNextIndex;

        if (!ctx) continue;

        // Remove completed or stopped coroutines
        if (ctx->is_completed()) {
            remove(ctx);
            continue;
        }

        if (ctx->should_stop()) {
            ctx->stop_and_complete();
            remove(ctx);
            continue;
        }

        // Skip coroutines that aren't ready (e.g. awaiting a promise)
        if (!ctx->is_ready()) {
            continue;
        }

        // Resume this coroutine — it will run until it suspends
        ctx->resume();
    }
}

void CoroutineRunner::stop_all() FL_NOEXCEPT {
    for (size_t i = 0; i < mCount; ++i) {