diff options
Diffstat (limited to 'common/store.cpp')
-rw-r--r-- | common/store.cpp | 12 |
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 | ||