Fixed subscription handler logic.

This commit is contained in:
Brad Arant 2023-06-12 08:52:44 -07:00
parent b4fd28e41a
commit e78f0cd4f8
2 changed files with 3 additions and 3 deletions

View File

@ -28,7 +28,7 @@ namespace core {
if (handler) if (handler)
handler->onSubscribe(session, this); handler->onSubscribe(session, this);
else else
onSubscribe(session, this); onSubscribe(session);
subscribers.push_back(&session); subscribers.push_back(&session);
return 1; return 1;
@ -62,7 +62,7 @@ namespace core {
return (std::find(subscribers.begin(), subscribers.end(), &session) != subscribers.end()); return (std::find(subscribers.begin(), subscribers.end(), &session) != subscribers.end());
} }
int Subscription::onSubscribe(TCPSession &session, Subscription *subscription) { int Subscription::onSubscribe(TCPSession &session) {
return 0; return 0;
} }

View File

@ -24,7 +24,7 @@ namespace core
virtual int process(coreutils::ZString &request, std::stringstream &out, TCPSession &session); virtual int process(coreutils::ZString &request, std::stringstream &out, TCPSession &session);
virtual int onSubscribe(TCPSession &session, Subscription *subscription); virtual int onSubscribe(TCPSession &session);
int event(std::stringstream &out); int event(std::stringstream &out);