Work son subscriptions.

This commit is contained in:
Brad Arant committed 2022-02-09 14:46:52 +00:00
1 parent 16ffd60e75
commit 6cf321ceb4
2 files changed
+2 -2

No files matched your search

-1
View File
@@ -173,7 +173,6 @@ namespace core {
reset = false; reset = false;
// if(!needsToWrite()) // if(!needsToWrite())
delete this; delete this;
} }
} }
+2 -1
View File
@@ -17,7 +17,7 @@ namespace core {
countSubscribed += (*subscription).second->unsubscribe(session); countSubscribed += (*subscription).second->unsubscribe(session);
if((*subscription).second->owner == &session) { if((*subscription).second->owner == &session) {
subscription = subscriptions.erase(subscription); subscription = subscriptions.erase(subscription);
delete (*subscription).second; // delete (*subscription).second;
++countPublished; ++countPublished;
} else } else
++subscription; ++subscription;
@@ -54,6 +54,7 @@ namespace core {
} else if(request[0].equals("unsubscribe")) { } else if(request[0].equals("unsubscribe")) {
subscription->unsubscribe(session); subscription->unsubscribe(session);
} else if(request[0].equals("event")) { } else if(request[0].equals("event")) {
// coreutils::Log(coreutils::LOG_DEBUG_2) << "request: [" << request << "].";
if(subscription->owner == &session) { if(subscription->owner == &session) {
std::stringstream out; std::stringstream out;
subscription->process(request, out); subscription->process(request, out);