summaryrefslogtreecommitdiffstats
path: root/common/queryrunner.h
diff options
context:
space:
mode:
Diffstat (limited to 'common/queryrunner.h')
-rw-r--r--common/queryrunner.h9
1 files changed, 8 insertions, 1 deletions
diff --git a/common/queryrunner.h b/common/queryrunner.h
index 35093e2..e449570 100644
--- a/common/queryrunner.h
+++ b/common/queryrunner.h
@@ -77,7 +77,7 @@ private:
77 * QueryRunner has to keep ResourceAccess alive in order to keep getting updates. 77 * QueryRunner has to keep ResourceAccess alive in order to keep getting updates.
78 */ 78 */
79template <typename DomainType> 79template <typename DomainType>
80class QueryRunner : public QueryRunnerBase 80class SINK_EXPORT QueryRunner : public QueryRunnerBase
81{ 81{
82public: 82public:
83 QueryRunner(const Sink::Query &query, const Sink::ResourceContext &context, const QByteArray &bufferType, const Sink::Log::Context &logCtx); 83 QueryRunner(const Sink::Query &query, const Sink::ResourceContext &context, const QByteArray &bufferType, const Sink::Log::Context &logCtx);
@@ -91,6 +91,11 @@ public:
91 91
92 typename Sink::ResultEmitter<typename DomainType::Ptr>::Ptr emitter(); 92 typename Sink::ResultEmitter<typename DomainType::Ptr>::Ptr emitter();
93 93
94 /**
95 * For testing only.
96 */
97 void delayNextQuery();
98
94private: 99private:
95 void fetch(const Sink::Query &query, const QByteArray &bufferType); 100 void fetch(const Sink::Query &query, const QByteArray &bufferType);
96 KAsync::Job<void> incrementalFetch(const Sink::Query &query, const QByteArray &bufferType); 101 KAsync::Job<void> incrementalFetch(const Sink::Query &query, const QByteArray &bufferType);
@@ -106,4 +111,6 @@ private:
106 bool mInitialQueryComplete = false; 111 bool mInitialQueryComplete = false;
107 bool mQueryInProgress = false; 112 bool mQueryInProgress = false;
108 bool mRequestFetchMore = false; 113 bool mRequestFetchMore = false;
114 bool mDelayNextQuery = false;
115 bool mRevisionChangedMeanwhile = false;
109}; 116};