communication_group_server.h

#ifndef COMMUNICATION_GROUP_SERVER_H
#define COMMUNICATION_GROUP_SERVER_H
 
#include <stdint.h>
#include <functional>
#include <future>
#include <vector>
 
namespace ara
{
    namespace com
    {
        namespace cg
        {
            template <typename R>
            using ResponseHandler = std::function<void(uint32_t, R)>;
 
            template <typename T, typename R>
            class CommunicationGroupServer
            {
            private:
                ResponseHandler<R> mResponseHandler;
                std::vector<uint32_t> mClients;
 
            public:
                explicit CommunicationGroupServer(ResponseHandler<R> responseHandler) : mResponseHandler{responseHandler}
                {
                }
 
                ~CommunicationGroupServer() noexcept = default;
 
                std::future<void> Broadcast(const T &msg) const;
 
                std::future<void> Message(uint32_t clientID, const T &msg) const;
 
                void Response(uint32_t clientID, const R &responseMsg)
                {
                    mResponseHandler(clientID, responseMsg);
                }
 
                std::future<std::vector<uint32_t>> ListClients() const;
            };
        }
    }
}
 
#endif