Subscriber.h

 
#ifndef ACTIVE_EVENT_SUBSCRIBER
#define ACTIVE_EVENT_SUBSCRIBER
 
#include "Active/Event/Participant.h"
 
#include <set>
 
namespace active::event {
    
    class Event;
    class Publisher;
        
    class Subscriber : public Participant {
    public:
                
        // MARK: - Types
        
        using Unique = std::unique_ptr<Subscriber>;
        using Shared = std::shared_ptr<Subscriber>;
        using Weak = std::weak_ptr<Subscriber>;
        using Subscription = std::set<NameID>;
 
        enum class Action {
            issue = 0,  
            suspend,    
            renew,  
            discontinue,    
        };
 
        // MARK: - Constructors
        
        Subscriber(int32_t priority = 0) { m_priority = priority; }
        Subscriber(const utility::NameID& identity, int32_t priority = 0) : Participant{identity} { m_priority = priority; }
        virtual ~Subscriber() = default;
        
        // MARK: - Operators
 
        bool operator== (const Subscriber& ref) const { return Participant::operator==(ref); }
        bool operator!= (const Subscriber& ref) const { return !(*this == ref); }
        
        // MARK: - Functions (const)
        
        virtual bool getPriority() const { return m_priority; }
        virtual Action action() const { return m_action; }
        virtual Subscription subscription() const = 0;
        
        // MARK: - Functions (mutating)
        
        virtual bool receive(const Event& event) = 0;
        
    protected:
        friend class Publisher;
        
        void setAction(Action action) { m_action = action; }
        
    private:
        int32_t m_priority = 0;
        Action m_action = Action::issue;
    };
    
}
 
#endif  //ACTIVE_EVENT_SUBSCRIBER