diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-08-16 12:45:17 +0200 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-08-18 18:48:06 +0200 |
commit | 726a49431909dbd8bdc6efdb8a36ddf4214a7328 (patch) | |
tree | 48103c645dac6aaa0f4eba6cea89ab347333329d /common/messagequeue.h | |
parent | c7f813895866981ef97c99ed52d2d2a80dc13178 (diff) | |
download | sink-726a49431909dbd8bdc6efdb8a36ddf4214a7328.tar.gz sink-726a49431909dbd8bdc6efdb8a36ddf4214a7328.zip |
Batch dequeue in messagequeue.
The messagequeue removes all dequeued values once all values have been
processed in a single transaction.
Diffstat (limited to 'common/messagequeue.h')
-rw-r--r-- | common/messagequeue.h | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/common/messagequeue.h b/common/messagequeue.h index c5e32db..8ea8d8b 100644 --- a/common/messagequeue.h +++ b/common/messagequeue.h | |||
@@ -33,7 +33,7 @@ public: | |||
33 | //TODO track processing progress to avoid processing the same message with the same preprocessor twice? | 33 | //TODO track processing progress to avoid processing the same message with the same preprocessor twice? |
34 | void dequeue(const std::function<void(void *ptr, int size, std::function<void(bool success)>)> & resultHandler, | 34 | void dequeue(const std::function<void(void *ptr, int size, std::function<void(bool success)>)> & resultHandler, |
35 | const std::function<void(const Error &error)> &errorHandler); | 35 | const std::function<void(const Error &error)> &errorHandler); |
36 | KAsync::Job<void> dequeueBatch(int maxBatchSize, const std::function<void(void *ptr, int size, std::function<void(bool success)>)> & resultHandler); | 36 | KAsync::Job<void> dequeueBatch(int maxBatchSize, const std::function<KAsync::Job<void>(const QByteArray &)> &resultHandler); |
37 | bool isEmpty(); | 37 | bool isEmpty(); |
38 | signals: | 38 | signals: |
39 | void messageReady(); | 39 | void messageReady(); |