Ensure we always process the full queue and that flushing works.

1 files changed, 5 insertions, 2 deletions

diff --git a/common/changereplay.cpp b/common/changereplay.cpp
index a0796eb..13ed49e 100644
--- a/common/changereplay.cpp
+++ b/common/changereplay.cpp
@@ -154,9 +154,12 @@ KAsync::Job<void> ChangeReplay::replayNextRevision()
         .syncThen<void>([this, lastReplayedRevision]() {
             recordReplayedRevision(*lastReplayedRevision);
             mMainStoreTransaction.abort();
-            if (allChangesReplayed()) {
+            if (ChangeReplay::allChangesReplayed()) {
                 mReplayInProgress = false;
-                emit changesReplayed();
+                //In case we have a derived implementation
+                if (allChangesReplayed()) {
+                    emit changesReplayed();
+                }
             } else {
                 QTimer::singleShot(0, [this]() {
                     mReplayInProgress = false;