summaryrefslogtreecommitdiffstats
path: root/common/commandprocessor.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'common/commandprocessor.cpp')
-rw-r--r--common/commandprocessor.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/common/commandprocessor.cpp b/common/commandprocessor.cpp
index 20fcf3a..efcd077 100644
--- a/common/commandprocessor.cpp
+++ b/common/commandprocessor.cpp
@@ -227,7 +227,7 @@ KAsync::Job<void> CommandProcessor::processQueue(MessageQueue *queue)
227{ 227{
228 auto time = QSharedPointer<QTime>::create(); 228 auto time = QSharedPointer<QTime>::create();
229 return KAsync::syncStart<void>([this]() { mPipeline->startTransaction(); }) 229 return KAsync::syncStart<void>([this]() { mPipeline->startTransaction(); })
230 .then(KAsync::dowhile( 230 .then(KAsync::doWhile(
231 [this, queue, time]() -> KAsync::Job<KAsync::ControlFlowFlag> { 231 [this, queue, time]() -> KAsync::Job<KAsync::ControlFlowFlag> {
232 return queue->dequeueBatch(sBatchSize, 232 return queue->dequeueBatch(sBatchSize,
233 [this, time](const QByteArray &data) -> KAsync::Job<void> { 233 [this, time](const QByteArray &data) -> KAsync::Job<void> {
@@ -265,7 +265,7 @@ KAsync::Job<void> CommandProcessor::processPipeline()
265 return KAsync::null<void>(); 265 return KAsync::null<void>();
266 } 266 }
267 auto it = QSharedPointer<QListIterator<MessageQueue *>>::create(mCommandQueues); 267 auto it = QSharedPointer<QListIterator<MessageQueue *>>::create(mCommandQueues);
268 return KAsync::dowhile( 268 return KAsync::doWhile(
269 [it, this]() { 269 [it, this]() {
270 auto time = QSharedPointer<QTime>::create(); 270 auto time = QSharedPointer<QTime>::create();
271 time->start(); 271 time->start();