diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2018-02-22 10:16:18 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2018-02-22 10:16:18 +0100 |
commit | 2beb09e8b3f4922a15ec0abde737d4cf9b9d4f8b (patch) | |
tree | 50115abf9b041d66ab9e4242af52cd16a7a9a3db /common/datastorequery.h | |
parent | 280b1250c0a038c2cf09fae3848ed0adefecc430 (diff) | |
download | sink-2beb09e8b3f4922a15ec0abde737d4cf9b9d4f8b.tar.gz sink-2beb09e8b3f4922a15ec0abde737d4cf9b9d4f8b.zip |
Deal with removals in reduced queries
Diffstat (limited to 'common/datastorequery.h')
-rw-r--r-- | common/datastorequery.h | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/common/datastorequery.h b/common/datastorequery.h index 8800644..2311585 100644 --- a/common/datastorequery.h +++ b/common/datastorequery.h | |||
@@ -62,6 +62,7 @@ private: | |||
62 | QVector<QByteArray> indexLookup(const QByteArray &property, const QVariant &value); | 62 | QVector<QByteArray> indexLookup(const QByteArray &property, const QVariant &value); |
63 | 63 | ||
64 | void readEntity(const QByteArray &key, const BufferCallback &resultCallback); | 64 | void readEntity(const QByteArray &key, const BufferCallback &resultCallback); |
65 | void readPrevious(const QByteArray &key, const std::function<void (const Sink::ApplicationDomain::ApplicationDomainType &)> &callback); | ||
65 | 66 | ||
66 | ResultSet createFilteredSet(ResultSet &resultSet, const FilterFunction &); | 67 | ResultSet createFilteredSet(ResultSet &resultSet, const FilterFunction &); |
67 | QVector<QByteArray> loadIncrementalResultSet(qint64 baseRevision); | 68 | QVector<QByteArray> loadIncrementalResultSet(qint64 baseRevision); |
@@ -107,6 +108,12 @@ public: | |||
107 | return mDatastore->indexLookup(property, value); | 108 | return mDatastore->indexLookup(property, value); |
108 | } | 109 | } |
109 | 110 | ||
111 | void readPrevious(const QByteArray &key, const std::function<void (const Sink::ApplicationDomain::ApplicationDomainType &)> &callback) | ||
112 | { | ||
113 | Q_ASSERT(mDatastore); | ||
114 | mDatastore->readPrevious(key, callback); | ||
115 | } | ||
116 | |||
110 | virtual void skip() { mSource->skip(); } | 117 | virtual void skip() { mSource->skip(); } |
111 | 118 | ||
112 | //Returns true for as long as a result is available | 119 | //Returns true for as long as a result is available |