#pragma once

#include <cassert>
#include <deque>
#include <optional>
#include <utility>

#include "infra/port.h"
#include "infra/sim.h"

namespace infra {
    template<typename T, unsigned int size> struct queue : public sim {
        port<T> input;
        port<T> *output = nullptr;
        std::deque<T> elements;

        void clock() {
            if (input.can_read() && elements.size() < size) {
                auto x = input.read();
                elements.emplace_back(std::move(x));
            }
            if (output->can_write() && !elements.empty()) {
                auto &x = elements.front();
                output->write(std::move(x));
                elements.pop_front();
            }
        }
    };
}