diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2018-02-21 15:47:50 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2018-02-21 15:47:50 +0100 |
commit | d2d8a85aa6c56195368f7ec563a98afb6861acd9 (patch) | |
tree | babd7454902b7e3a83b82b04cf5ffca5720aca12 /common/queryrunner.cpp | |
parent | 17f0dd179e9fd57b41b29abe84e7e49f9a7ac8a8 (diff) | |
download | sink-d2d8a85aa6c56195368f7ec563a98afb6861acd9.tar.gz sink-d2d8a85aa6c56195368f7ec563a98afb6861acd9.zip |
Remember aggregated ids
Diffstat (limited to 'common/queryrunner.cpp')
-rw-r--r-- | common/queryrunner.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/common/queryrunner.cpp b/common/queryrunner.cpp index 0ed4cb5..2062828 100644 --- a/common/queryrunner.cpp +++ b/common/queryrunner.cpp | |||
@@ -45,7 +45,6 @@ struct ReplayResult { | |||
45 | template <typename DomainType> | 45 | template <typename DomainType> |
46 | class QueryWorker : public QObject | 46 | class QueryWorker : public QObject |
47 | { | 47 | { |
48 | typedef std::function<bool(const typename DomainType::Ptr &domainObject, Sink::Operation operation, const QMap<QByteArray, QVariant> &aggregateValues)> ResultCallback; | ||
49 | public: | 48 | public: |
50 | QueryWorker(const Sink::Query &query, const ResourceContext &context, const QByteArray &bufferType, const QueryRunnerBase::ResultTransformation &transformation, const Sink::Log::Context &logCtx); | 49 | QueryWorker(const Sink::Query &query, const ResourceContext &context, const QByteArray &bufferType, const QueryRunnerBase::ResultTransformation &transformation, const Sink::Log::Context &logCtx); |
51 | virtual ~QueryWorker(); | 50 | virtual ~QueryWorker(); |
@@ -210,6 +209,7 @@ void QueryWorker<DomainType>::resultProviderCallback(const Sink::Query &query, S | |||
210 | for (auto it = result.aggregateValues.constBegin(); it != result.aggregateValues.constEnd(); it++) { | 209 | for (auto it = result.aggregateValues.constBegin(); it != result.aggregateValues.constEnd(); it++) { |
211 | valueCopy->setProperty(it.key(), it.value()); | 210 | valueCopy->setProperty(it.key(), it.value()); |
212 | } | 211 | } |
212 | valueCopy->aggregatedIds() = result.aggregateIds; | ||
213 | if (mResultTransformation) { | 213 | if (mResultTransformation) { |
214 | mResultTransformation(*valueCopy); | 214 | mResultTransformation(*valueCopy); |
215 | } | 215 | } |