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 2e2e96d..052db39 100644 --- a/common/queryrunner.cpp +++ b/common/queryrunner.cpp | |||
| @@ -86,7 +86,7 @@ QueryRunner<DomainType>::QueryRunner(const Sink::Query &query, const Sink::Resou | |||
| 86 | const auto newRevisionAndReplayedEntities = worker.executeInitialQuery(query, parent, *resultProvider, mOffset[parentId], mBatchSize); | 86 | const auto newRevisionAndReplayedEntities = worker.executeInitialQuery(query, parent, *resultProvider, mOffset[parentId], mBatchSize); |
| 87 | return newRevisionAndReplayedEntities; | 87 | return newRevisionAndReplayedEntities; |
| 88 | }) | 88 | }) |
| 89 | .template then<void, QPair<qint64, qint64>>([=](const QPair<qint64, qint64> &newRevisionAndReplayedEntities) { | 89 | .template syncThen<void, QPair<qint64, qint64>>([=](const QPair<qint64, qint64> &newRevisionAndReplayedEntities) { |
| 90 | mOffset[parentId] += newRevisionAndReplayedEntities.second; | 90 | mOffset[parentId] += newRevisionAndReplayedEntities.second; |
| 91 | // Only send the revision replayed information if we're connected to the resource, there's no need to start the resource otherwise. | 91 | // Only send the revision replayed information if we're connected to the resource, there's no need to start the resource otherwise. |
| 92 | if (query.liveQuery) { | 92 | if (query.liveQuery) { |
| @@ -110,7 +110,7 @@ QueryRunner<DomainType>::QueryRunner(const Sink::Query &query, const Sink::Resou | |||
| 110 | const auto newRevisionAndReplayedEntities = worker.executeIncrementalQuery(query, *resultProvider); | 110 | const auto newRevisionAndReplayedEntities = worker.executeIncrementalQuery(query, *resultProvider); |
| 111 | return newRevisionAndReplayedEntities; | 111 | return newRevisionAndReplayedEntities; |
| 112 | }) | 112 | }) |
| 113 | .template then<void, QPair<qint64, qint64> >([query, this, resultProvider](const QPair<qint64, qint64> &newRevisionAndReplayedEntities) { | 113 | .template syncThen<void, QPair<qint64, qint64> >([query, this, resultProvider](const QPair<qint64, qint64> &newRevisionAndReplayedEntities) { |
| 114 | // Only send the revision replayed information if we're connected to the resource, there's no need to start the resource otherwise. | 114 | // Only send the revision replayed information if we're connected to the resource, there's no need to start the resource otherwise. |
| 115 | mResourceAccess->sendRevisionReplayedCommand(newRevisionAndReplayedEntities.first); | 115 | mResourceAccess->sendRevisionReplayedCommand(newRevisionAndReplayedEntities.first); |
| 116 | resultProvider->setRevision(newRevisionAndReplayedEntities.first); | 116 | resultProvider->setRevision(newRevisionAndReplayedEntities.first); |