From 814a7ee53e01b015a3f3e28e1ab3cf8752351bbe Mon Sep 17 00:00:00 2001 From: Alex Hultman Date: Tue, 28 Sep 2021 23:23:00 +0200 Subject: [PATCH] Clear outgoingMessages on last drained subscriber --- src/TopicTree.h | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/TopicTree.h b/src/TopicTree.h index 73eef97..a837128 100644 --- a/src/TopicTree.h +++ b/src/TopicTree.h @@ -252,6 +252,11 @@ public: /* This one always resets needsDrainage before it calls any cb's. * Otherwise we would stackoverflow when sending after publish but before drain. */ drainImpl(s); + + /* If we drained last subscriber, also clear outgoingMessages */ + if (!drainableSubscribers) { + outgoingMessages.clear(); + } } }