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, 22 insertions, 0 deletions

diff --git a/common/modelresult.cpp b/common/modelresult.cpp
index 935e2e8..65eaba9 100644
--- a/common/modelresult.cpp
+++ b/common/modelresult.cpp
@@ -183,6 +183,28 @@ void ModelResult<T, Ptr>::setFetcher(const std::function<void(const Ptr &parent)
 }
 
 template<class T, class Ptr>
+void ModelResult<T, Ptr>::setEmitter(const typename Akonadi2::ResultEmitter<Ptr>::Ptr &emitter)
+{
+    setFetcher(emitter->mFetcher);
+    emitter->onAdded([this](const Ptr &value) {
+        this->add(value);
+    });
+    emitter->onModified([this](const Ptr &value) {
+        this->modify(value);
+    });
+    emitter->onRemoved([this](const Ptr &value) {
+        this->remove(value);
+    });
+    emitter->onInitialResultSetComplete([this]() {
+    });
+    emitter->onComplete([this]() {
+    });
+    emitter->onClear([this]() {
+    });
+    mEmitter = emitter;
+}
+
+template<class T, class Ptr>
 void ModelResult<T, Ptr>::modify(const Ptr &value)
 {
     auto childId = qHash(value->identifier());