Publisher.h

 
#ifndef ACTIVE_EVENT_PUBLISHER
#define ACTIVE_EVENT_PUBLISHER
 
#include "Active/Event/Participant.h"
 
#include <mutex>
#include <vector>
 
namespace active::event {
    
    class Event;
    class Subscriber;
        
    class Publisher : public Participant {
    public:
                
        // MARK: - Types
        
        using Unique = std::unique_ptr<Publisher>;
        using Shared = std::shared_ptr<Publisher>;
 
        // MARK: - Constructors
        
        Publisher(const utility::NameID& identity = utility::NameID{});
        Publisher(const Publisher& source);
        virtual ~Publisher();
        
        // MARK: - Operators
        
        Publisher& operator= (const Publisher& source);
        
        
        // MARK: - Functions (mutating)
        
        bool publish(const Event& event);
        bool add(std::shared_ptr<Subscriber> subscriber);
        bool addWeak(std::shared_ptr<Subscriber> subscriber);
        template<class T, class... Args>
        std::shared_ptr<T> add(Args&&... args) {
            auto subscriber = std::make_shared<T>(std::forward<Args>(args)...);
            return add(subscriber) ? subscriber : nullptr;
        }
        bool remove(const Subscriber& subscriber);
        bool remove(const utility::Guid& id);
    
    protected:
        virtual bool audit() override;
        virtual bool attach() override;
        virtual bool start() override;
        virtual void stop() override;
        
    private:
        class SubscriberList;
        std::unique_ptr<SubscriberList> m_subscriber;
    };
    
}
 
#endif  //ACTIVE_EVENT_PUBLISHER