Error propagation should work now.

1 files changed, 2 insertions, 12 deletions

diff --git a/common/store.cpp b/common/store.cpp
index 0ecdcd2..7783f91 100644
--- a/common/store.cpp
+++ b/common/store.cpp
@@ -259,31 +259,21 @@ KAsync::Job<void> Store::synchronize(const Sink::Query &query)
 {
     auto resources = getResources(query).keys();
     SinkTrace() << "synchronize" << resources;
-    //FIXME only necessary because each doesn't propagate errors
-    auto errorFlag = new bool;
     return KAsync::value(resources)
-        .template each([query, errorFlag](const QByteArray &resource) {
+        .template each([query](const QByteArray &resource) {
             SinkTrace() << "Synchronizing " << resource;
             auto resourceAccess = ResourceAccessFactory::instance().getAccess(resource, ResourceConfig::getResourceType(resource));
             resourceAccess->open();
             return resourceAccess->synchronizeResource(true, false)
                 .addToContext(resourceAccess)
-                .then<void>([errorFlag](const KAsync::Error &error) {
+                .then<void>([](const KAsync::Error &error) {
                         if (error) {
-                            *errorFlag = true;
                             SinkWarning() << "Error during sync.";
                             return KAsync::error<void>(error);
                         }
                         SinkTrace() << "synced.";
                         return KAsync::null<void>();
                     });
-        })
-        .then<void>([errorFlag]() {
-            if (*errorFlag) {
-                return KAsync::error<void>("Error during sync.");
-            }
-            delete errorFlag;
-            return KAsync::null<void>();
         });
 }