channel.h

#ifndef _ELMA_CHANNEL_H
#define _ELMA_CHANNEL_H

#include <string>
#include <deque>
#include <json/json.h>

#include "elma.h"

namespace elma {

    using std::string;
    using std::deque;
    using nlohmann::json; 


    class Channel {

        public:

        Channel(string name) : _name(name), _capacity(100) {}

        Channel(string name, int capacity) : _name(name), _capacity(capacity) {}

        Channel& send(json);
        Channel& flush();
        json latest();
        json earliest();

        inline int size() { return _queue.size(); }

        inline bool empty() { return _queue.size() == 0; }

        inline bool nonempty() { return _queue.size() > 0; }

        inline string name() { return _name; }

        inline int capacity() { return _capacity; }

        private:

        string _name;
        int _capacity;
        deque<json> _queue;

    };

}

#endif