ActionInputBuffer.h

浏览该文件的文档.

#pragma once
#include "common/Export.h"
 
#include "common/Result.h"
#include "common/SubjectRef.h"
#include "common/Time.h"
 
#include <cstdint>
#include <deque>
#include <map>
#include <string>
#include <vector>
 
namespace eve::action::input {
 
struct BufferedInput {
    SubjectRef     subject;
    std::string    input;
    SimulationTick tick = SimulationTick::zero();
    std::int32_t   priority = 0;
};
 
class EVENGINE_API_BACKENDS ActionInputBuffer {
public:
    ActionInputBuffer(std::uint32_t capacity, std::uint32_t lifetimeTicks);
 
    [[nodiscard]] Result<void> push(BufferedInput input);
    [[nodiscard]] Result<void> expire(SimulationTick now);
    [[nodiscard]] Result<BufferedInput> consume(SubjectRef subject, const std::vector<std::string>& allows);
    [[nodiscard]] Result<BufferedInput> peek(SubjectRef subject, const std::vector<std::string>& allows) const;
    void clear(SubjectRef subject);
    void clearAll() noexcept { entries_.clear(); }
    [[nodiscard]] std::size_t size() const noexcept { return entries_.size(); }
 
private:
    std::uint32_t            capacity_      = 1;
    std::uint32_t            lifetimeTicks_ = 1;
    std::deque<BufferedInput> entries_;
};
 
}  // namespace eve::action::input