Subscription.h

#ifndef __Subscription_h__
#define __Subscription_h__
 
#include "ZString.h"
#include <vector>
#include <string>
 
namespace core {
 
   class TCPSession;
 
   class Subscription {
 
   public:
      Subscription(std::string id);
      Subscription(std::string id, TCPSession &session);
      virtual ~Subscription();
 
      int subscribe(TCPSession &session);
      int unsubscribe(TCPSession &session);
 
      virtual int process(coreutils::ZString &request, std::stringstream &out);
      virtual int onSubscribe(TCPSession &session);
 
      int event(std::stringstream &out);
 
      //      int processCommand(coreutils::ZString &request, TCPSession &session) override;
 
      std::string id;
      TCPSession *owner;
 
      std::vector<TCPSession *> subscribers;
        
   };
}
 
#endif