diff options
Diffstat (limited to 'common/commandprocessor.cpp')
-rw-r--r-- | common/commandprocessor.cpp | 4 |
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(); |