summaryrefslogtreecommitdiffstats
path: root/common/store.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'common/store.cpp')
-rw-r--r--common/store.cpp12
1 files changed, 3 insertions, 9 deletions
diff --git a/common/store.cpp b/common/store.cpp
index 1701a43..b16fa4e 100644
--- a/common/store.cpp
+++ b/common/store.cpp
@@ -136,12 +136,6 @@ QPair<typename AggregatingResultEmitter<typename DomainType::Ptr>::Ptr, typenam
136 Q_ASSERT(!resourceType.isEmpty()); 136 Q_ASSERT(!resourceType.isEmpty());
137 queryResource<DomainType>(resourceType, resource->identifier(), query, aggregatingEmitter, ctx).exec(); 137 queryResource<DomainType>(resourceType, resource->identifier(), query, aggregatingEmitter, ctx).exec();
138 }); 138 });
139 emitter->onModified([](const ApplicationDomain::SinkResource::Ptr &) {
140 });
141 emitter->onRemoved([](const ApplicationDomain::SinkResource::Ptr &) {
142 });
143 emitter->onInitialResultSetComplete([](const ApplicationDomain::SinkResource::Ptr &, bool) {
144 });
145 emitter->onComplete([query, aggregatingEmitter, resourceCtx]() { 139 emitter->onComplete([query, aggregatingEmitter, resourceCtx]() {
146 SinkTraceCtx(resourceCtx) << "Resource query complete"; 140 SinkTraceCtx(resourceCtx) << "Resource query complete";
147 }); 141 });
@@ -178,7 +172,7 @@ QSharedPointer<QAbstractItemModel> Store::loadModel(const Query &query)
178 //Keep the emitter alive 172 //Keep the emitter alive
179 if (auto resourceEmitter = result.second) { 173 if (auto resourceEmitter = result.second) {
180 model->setProperty("resourceEmitter", QVariant::fromValue(resourceEmitter)); //TODO only neceesary for live queries 174 model->setProperty("resourceEmitter", QVariant::fromValue(resourceEmitter)); //TODO only neceesary for live queries
181 resourceEmitter->fetch(ApplicationDomain::SinkResource::Ptr()); 175 resourceEmitter->fetch();
182 } 176 }
183 177
184 178
@@ -443,10 +437,10 @@ QList<DomainType> Store::read(const Sink::Query &query_)
443 }); 437 });
444 438
445 if (auto resourceEmitter = result.second) { 439 if (auto resourceEmitter = result.second) {
446 resourceEmitter->fetch(ApplicationDomain::SinkResource::Ptr()); 440 resourceEmitter->fetch();
447 } 441 }
448 442
449 aggregatingEmitter->fetch(typename DomainType::Ptr()); 443 aggregatingEmitter->fetch();
450 return list; 444 return list;
451} 445}
452 446