channel.cc

#include <iostream>
#include <stdexcept>
#include "elma.h"

namespace elma { 
    
    Channel& Channel::send(json value) {
        _queue.push_front(value);
        while ( _queue.size() > capacity() ) {
            _queue.pop_back();
        }
        return *this;
    }

    Channel& Channel::flush() {
        _queue.clear();
        return *this;
    }

    json Channel::latest() {
        if ( _queue.size() == 0 ) {
            throw Exception("Tried to get the latest value in an empty channel.");
        }
        return _queue.front();
    }

    json Channel::earliest() {
        if ( _queue.size() == 0 ) {
            throw Exception("Tried to get the earliest value in an empty channel.");
        }
        return _queue.back();        
    }    

}