Fixed sync, detect errors during sync, wait until sync items are processed until signalling completion.

1 files changed, 3 insertions, 0 deletions

diff --git a/common/messagequeue.cpp b/common/messagequeue.cpp
index 99a0112..3754b16 100644
--- a/common/messagequeue.cpp
+++ b/common/messagequeue.cpp
@@ -31,6 +31,9 @@ void MessageQueue::dequeue(const std::function<void(void *ptr, int size, std::fu
         resultHandler(valuePtr, valueSize, [this, key](bool success) {
             if (success) {
                 mStorage.remove(key.data(), key.size());
+                if (isEmpty()) {
+                    emit this->drained();
+                }
             } else {
                 //TODO re-enqueue?
             }