Clear no longer subscribed-to Topics when draining
This commit is contained in:
@@ -291,6 +291,11 @@ public:
|
|||||||
for (int i = 0; i < numTriggeredTopics; i++) {
|
for (int i = 0; i < numTriggeredTopics; i++) {
|
||||||
if (triggeredTopics[i]->subs.size()) {
|
if (triggeredTopics[i]->subs.size()) {
|
||||||
triggeredTopics[numFilteredTriggeredTopics++] = triggeredTopics[i];
|
triggeredTopics[numFilteredTriggeredTopics++] = triggeredTopics[i];
|
||||||
|
} else {
|
||||||
|
/* If we no longer have any subscribers, yet still keep this Topic alive (parent),
|
||||||
|
* make sure to clear its potential messages. */
|
||||||
|
triggeredTopics[i]->messages.clear();
|
||||||
|
triggeredTopics[i]->triggered = false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
numTriggeredTopics = numFilteredTriggeredTopics;
|
numTriggeredTopics = numFilteredTriggeredTopics;
|
||||||
|
|||||||
Reference in New Issue
Block a user