diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-02-05 17:13:53 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-02-05 17:13:53 +0100 |
commit | 36a742c33f0a3144ed8d5dbaf56d7b4ef4e4e3d3 (patch) | |
tree | 7e00ae5d7dd2cb81d694c633e383ed4e932583ac /common/queryrunner.cpp | |
parent | 36ba8e177e519974296ff368544fc994896497c6 (diff) | |
download | sink-36a742c33f0a3144ed8d5dbaf56d7b4ef4e4e3d3.tar.gz sink-36a742c33f0a3144ed8d5dbaf56d7b4ef4e4e3d3.zip |
Use default captures where it makes sense
Diffstat (limited to 'common/queryrunner.cpp')
-rw-r--r-- | common/queryrunner.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/common/queryrunner.cpp b/common/queryrunner.cpp index 63b5bcf..a62c64c 100644 --- a/common/queryrunner.cpp +++ b/common/queryrunner.cpp | |||
@@ -75,7 +75,7 @@ QueryRunner<DomainType>::QueryRunner(const Sink::Query &query, const Sink::Resou | |||
75 | { | 75 | { |
76 | Trace() << "Starting query"; | 76 | Trace() << "Starting query"; |
77 | //We delegate loading of initial data to the result provider, os it can decide for itself what it needs to load. | 77 | //We delegate loading of initial data to the result provider, os it can decide for itself what it needs to load. |
78 | mResultProvider->setFetcher([this, query, instanceIdentifier, factory, bufferType](const typename DomainType::Ptr &parent) { | 78 | mResultProvider->setFetcher([=](const typename DomainType::Ptr &parent) { |
79 | Trace() << "Running fetcher"; | 79 | Trace() << "Running fetcher"; |
80 | auto resultProvider = mResultProvider; | 80 | auto resultProvider = mResultProvider; |
81 | async::run<qint64>([query, instanceIdentifier, factory, bufferType, parent, resultProvider]() -> qint64 { | 81 | async::run<qint64>([query, instanceIdentifier, factory, bufferType, parent, resultProvider]() -> qint64 { |
@@ -94,10 +94,10 @@ QueryRunner<DomainType>::QueryRunner(const Sink::Query &query, const Sink::Resou | |||
94 | // In case of a live query we keep the runner for as long alive as the result provider exists | 94 | // In case of a live query we keep the runner for as long alive as the result provider exists |
95 | if (query.liveQuery) { | 95 | if (query.liveQuery) { |
96 | //Incremental updates are always loaded directly, leaving it up to the result to discard the changes if they are not interesting | 96 | //Incremental updates are always loaded directly, leaving it up to the result to discard the changes if they are not interesting |
97 | setQuery([this, query, instanceIdentifier, factory, bufferType] () -> KAsync::Job<void> { | 97 | setQuery([=] () -> KAsync::Job<void> { |
98 | auto resultProvider = mResultProvider; | 98 | auto resultProvider = mResultProvider; |
99 | return async::run<qint64>([query, instanceIdentifier, factory, bufferType, resultProvider]() -> qint64 { | ||
100 | QueryWorker<DomainType> worker(query, instanceIdentifier, factory, bufferType); | 99 | QueryWorker<DomainType> worker(query, instanceIdentifier, factory, bufferType); |
100 | return async::run<qint64>([=]() -> qint64 { | ||
101 | const qint64 newRevision = worker.executeIncrementalQuery(query, *resultProvider); | 101 | const qint64 newRevision = worker.executeIncrementalQuery(query, *resultProvider); |
102 | return newRevision; | 102 | return newRevision; |
103 | }) | 103 | }) |