Function await_top_level

src/fl/task/executor.h:186–241

/// @endcode
template<typename T>
PromiseResult<T> await_top_level(Promise<T> p) {
    // Handle invalid promises
    if (!p.valid()) {
        return PromiseResult<T>(Error("Invalid promise"));
    }

    // If already completed, return immediately
    if (p.is_completed()) {
        if (p.is_resolved()) {
            return PromiseResult<T>(p.value());
        } else {
            return PromiseResult<T>(p.error());
        }
    }

    // Track recursion depth to prevent infinite loops
    int& await_depth = detail::await_depth_tls();
    if (await_depth > 10) {
        return PromiseResult<T>(Error("await_top_level recursion limit exceeded - possible infinite loop"));
    }

    ++await_depth;

    // Wait for promise to complete while pumping async tasks
    int pump_count = 0;
    const int max_pump_iterations = 10000; // Safety limit

    while (!p.is_completed() && pump_count < max_pump_iterations) {
        // Update the promise first (in case it's not managed by async system)
        p.update();

        // Check if completed after update
        if (p.is_completed()) {
            break;
        }

        // Platform-agnostic async pump and yield
        run(1000);

        ++pump_count;
    }

    --await_depth;

    // Check for timeout
    if (pump_count >= max_pump_iterations) {
        return PromiseResult<T>(Error("await_top_level timeout - promise did not complete"));
    }

    // Return the result
    if (p.is_resolved()) {
        return PromiseResult<T>(p.value());
    } else {
        return PromiseResult<T>(p.error());
    }
}

} // namespace task