We want the sync to be blocking

... which is only possible if we flush
after issuing the sync.

1 files changed, 4 insertions, 1 deletions

diff --git a/sinksh/syntax_modules/sink_sync.cpp b/sinksh/syntax_modules/sink_sync.cpp
index 1c7ed0f..d4a0e1c 100644
--- a/sinksh/syntax_modules/sink_sync.cpp
+++ b/sinksh/syntax_modules/sink_sync.cpp
@@ -23,6 +23,7 @@
 
 #include "common/resource.h"
 #include "common/storage.h"
+#include "common/resourcecontrol.h"
 #include "common/domain/event.h"
 #include "common/domain/folder.h"
 #include "common/resourceconfig.h"
@@ -45,7 +46,9 @@ bool sync(const QStringList &args, State &state)
     }
 
     QTimer::singleShot(0, [query, state]() {
-    Sink::Store::synchronize(query).syncThen<void>([state](const KAsync::Error &error) {
+    Sink::Store::synchronize(query)
+        .then(Sink::ResourceControl::flushReplayQueue(query.getResourceFilter().ids))
+        .syncThen<void>([state](const KAsync::Error &error) {
             if (error) {
                 state.printLine("Synchronization failed!");
             } else {