repo_broadcaster.h

#pragma once
#include <vector>
#include <iostream>

#include <algorithm>                       // copy, min
#include <iosfwd>                          // streamsize
#include <boost/iostreams/categories.hpp>  // sink_tag

#include <boost/iostreams/concepts.hpp>
#include <boost/iostreams/stream_buffer.hpp>

#include "repo_listener_abstract.h"

namespace repo{
    namespace  lib{
        class RepoBroadcaster : public boost::iostreams::sink
        {
        public:
            ~RepoBroadcaster();

            //static RepoBroadcaster* getInstance();
            RepoBroadcaster();

            void subscribe(RepoAbstractListener *subscriber)
            {
                if (subscriber)
                    subscribers.push_back(subscriber);
            }

            std::streamsize write(const char* s, std::streamsize n);

        private:

            std::vector<RepoAbstractListener *> subscribers;
        };
    }
}