awaiter_fiber.h

//
// Created by konstantin on 06.06.24.
//

#pragma once

#include <context/buffer/buffer.h>
#include <coro/stackfull_coro.h>
#include <executor/executor.h>
#include <executor/task/task_base.h>

namespace NFibers {

class IAwaiter;

class AwaiterFiber final : public NExecutors::TaskBase {
public:
    AwaiterFiber(NExecutors::IExecutor* executor, NCoro::Routine routine,
                 NContext::Buffer&& buffer);

    AwaiterFiber(const AwaiterFiber&) = delete;
    AwaiterFiber(AwaiterFiber&&) noexcept = delete;

    AwaiterFiber& operator=(const AwaiterFiber&) = delete;
    AwaiterFiber& operator=(AwaiterFiber&&) noexcept = delete;

    void Schedule();

    void Suspend(IAwaiter* waiter);
    void Switch();

    TaskRunResult Run() noexcept override;

    static AwaiterFiber* Self();

    NExecutors::IExecutor* GetScheduler();

private:
    NExecutors::IExecutor* executor_;
    NCoro::StackfullCoroutine fiber_coro_;
    IAwaiter* awaiter_{nullptr};
};

}  // namespace NFibers