Guard against destruction

We really need to guard against this in kasync...

1 files changed, 3 insertions, 0 deletions

diff --git a/common/changereplay.cpp b/common/changereplay.cpp
index 532cca8..4870551 100644
--- a/common/changereplay.cpp
+++ b/common/changereplay.cpp
@@ -99,6 +99,9 @@ KAsync::Job<void> ChangeReplay::replayNextRevision()
             SinkTraceCtx(mLogCtx) << "Changereplay from " << *lastReplayedRevision << " to " << *topRevision;
             return KAsync::doWhile(
                 [this, lastReplayedRevision, topRevision]() -> KAsync::Job<KAsync::ControlFlowFlag> {
+                    if (!mGuard) {
+                        return KAsync::value(KAsync::Break);
+                    }
                     if (*lastReplayedRevision >= *topRevision) {
                         SinkTraceCtx(mLogCtx) << "Done replaying";
                         return KAsync::value(KAsync::Break);