Class TaskCoroutineWasm

src/platforms/wasm/coroutine_runtime_wasm.impl.hpp:127–169

//=============================================================================

class TaskCoroutineWasm : public ICoroutineTask {
public:
    static TaskCoroutinePtr create(fl::string name,
                                    TaskFunction function,
                                    size_t stack_size = 4096,
                                    u8 priority = 5) FL_NOEXCEPT {
        auto* ctx = CoroutineContext::create(fl::move(function), stack_size);
        if (!ctx) {
            FL_WARN("TaskCoroutineWasm: Failed to create context for '"
                    << name << "'");
            return nullptr;
        }

        TaskCoroutinePtr task(new TaskCoroutineWasm()) FL_NOEXCEPT;  // ok bare allocation
        auto* impl = static_cast<TaskCoroutineWasm*>(task.get());
        impl->mName = fl::move(name);
        impl->mContext.reset(ctx);

        // Register with the global runner
        CoroutineRunner::instance().enqueue(ctx);

        return task;
    }

    ~TaskCoroutineWasm() override { stop(); }

    void stop() FL_NOEXCEPT override {
        if (!mContext) return;
        mContext->stop_and_complete();
        CoroutineRunner::instance().remove(mContext.get());
    }

    bool isRunning() const FL_NOEXCEPT override {
        if (!mContext) return false;
        return !mContext->is_completed();
    }

private:
    TaskCoroutineWasm() = default;

    fl::string mName;
    fl::unique_ptr<CoroutineContext> mContext;
};

//=============================================================================
// Factory function