diff options
Diffstat (limited to 'common/queryrunner.cpp')
-rw-r--r-- | common/queryrunner.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/common/queryrunner.cpp b/common/queryrunner.cpp index f1e21f4..6730894 100644 --- a/common/queryrunner.cpp +++ b/common/queryrunner.cpp | |||
@@ -94,7 +94,7 @@ QueryRunner<DomainType>::QueryRunner(const Sink::Query &query, const Sink::Resou | |||
94 | const auto newRevisionAndReplayedEntities = worker.executeInitialQuery(query, parent, *resultProvider, offset, batchSize); | 94 | const auto newRevisionAndReplayedEntities = worker.executeInitialQuery(query, parent, *resultProvider, offset, batchSize); |
95 | return newRevisionAndReplayedEntities; | 95 | return newRevisionAndReplayedEntities; |
96 | }) | 96 | }) |
97 | .template syncThen<void, ReplayResult>([this, parentId, query, parent, resultProvider, guardPtr](const ReplayResult &newRevisionAndReplayedEntities) { | 97 | .template then([this, parentId, query, parent, resultProvider, guardPtr](const ReplayResult &newRevisionAndReplayedEntities) { |
98 | if (!guardPtr) { | 98 | if (!guardPtr) { |
99 | qWarning() << "The parent object is already gone"; | 99 | qWarning() << "The parent object is already gone"; |
100 | return; | 100 | return; |
@@ -124,7 +124,7 @@ QueryRunner<DomainType>::QueryRunner(const Sink::Query &query, const Sink::Resou | |||
124 | const auto newRevisionAndReplayedEntities = worker.executeIncrementalQuery(query, *resultProvider); | 124 | const auto newRevisionAndReplayedEntities = worker.executeIncrementalQuery(query, *resultProvider); |
125 | return newRevisionAndReplayedEntities; | 125 | return newRevisionAndReplayedEntities; |
126 | }) | 126 | }) |
127 | .template syncThen<void, ReplayResult>([query, this, resultProvider, guardPtr](const ReplayResult &newRevisionAndReplayedEntities) { | 127 | .template then([query, this, resultProvider, guardPtr](const ReplayResult &newRevisionAndReplayedEntities) { |
128 | if (!guardPtr) { | 128 | if (!guardPtr) { |
129 | qWarning() << "The parent object is already gone"; | 129 | qWarning() << "The parent object is already gone"; |
130 | return; | 130 | return; |