summaryrefslogtreecommitdiffstats
path: root/common/messagequeue.h
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2015-08-16 12:45:17 +0200
committerChristian Mollekopf <chrigi_1@fastmail.fm>2015-08-18 18:48:06 +0200
commit726a49431909dbd8bdc6efdb8a36ddf4214a7328 (patch)
tree48103c645dac6aaa0f4eba6cea89ab347333329d /common/messagequeue.h
parentc7f813895866981ef97c99ed52d2d2a80dc13178 (diff)
downloadsink-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.h2
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();
38signals: 38signals:
39 void messageReady(); 39 void messageReady();