Introduced a QueryRunner object

The QueryRunner object lives for the duration of the query (so just
for the initial query for non-live queries, and for the lifetime of the
result model for live queries).
It's supposed to handle all the threading internally and decouple the
lifetime of the facade.

1 files changed, 12 insertions, 5 deletions

diff --git a/common/resourcefacade.cpp b/common/resourcefacade.cpp
index 1796271..3d207e4 100644
--- a/common/resourcefacade.cpp
+++ b/common/resourcefacade.cpp
@@ -54,9 +54,15 @@ KAsync::Job<void> ResourceFacade::remove(const Akonadi2::ApplicationDomain::Akon
     });
 }
 
-KAsync::Job<void> ResourceFacade::load(const Akonadi2::Query &query, Akonadi2::ResultProviderInterface<typename Akonadi2::ApplicationDomain::AkonadiResource::Ptr> &resultProvider)
+QPair<KAsync::Job<void>, typename Akonadi2::ResultEmitter<Akonadi2::ApplicationDomain::AkonadiResource::Ptr>::Ptr > ResourceFacade::load(const Akonadi2::Query &query)
 {
-    return KAsync::start<void>([query, &resultProvider]() {
+    auto resultProvider = new Akonadi2::ResultProvider<typename Akonadi2::ApplicationDomain::AkonadiResource::Ptr>();
+    auto emitter = resultProvider->emitter();
+    resultProvider->setFetcher([](const QSharedPointer<Akonadi2::ApplicationDomain::AkonadiResource> &) {});
+    resultProvider->onDone([resultProvider]() {
+        delete resultProvider;
+    });
+    auto job = KAsync::start<void>([query, resultProvider]() {
         const auto configuredResources = ResourceConfig::getResources();
         for (const auto &res : configuredResources.keys()) {
             const auto type = configuredResources.value(res);
@@ -64,12 +70,13 @@ KAsync::Job<void> ResourceFacade::load(const Akonadi2::Query &query, Akonadi2::R
                 auto resource = Akonadi2::ApplicationDomain::AkonadiResource::Ptr::create();
                 resource->setProperty("identifier", res);
                 resource->setProperty("type", type);
-                resultProvider.add(resource);
+                resultProvider->add(resource);
             }
         }
         //TODO initialResultSetComplete should be implicit
-        resultProvider.initialResultSetComplete();
-        resultProvider.complete();
+        resultProvider->initialResultSetComplete();
+        resultProvider->complete();
     });
+    return qMakePair(job, emitter);
 }