diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-12-28 12:05:34 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2018-01-02 13:31:14 +0100 |
commit | 625190d311adfcf3f0436cfece82249a92489348 (patch) | |
tree | 1010950e14b57560ae90abe20a5657750ad27137 /common/store.cpp | |
parent | 11b790ba6f06141db802273628ce2d191982677e (diff) | |
download | sink-625190d311adfcf3f0436cfece82249a92489348.tar.gz sink-625190d311adfcf3f0436cfece82249a92489348.zip |
No parent query
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 | ||