summaryrefslogtreecommitdiffstats
path: root/common/commandprocessor.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'common/commandprocessor.cpp')
-rw-r--r--common/commandprocessor.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/common/commandprocessor.cpp b/common/commandprocessor.cpp
index 5d5261f..33e2f81 100644
--- a/common/commandprocessor.cpp
+++ b/common/commandprocessor.cpp
@@ -227,7 +227,7 @@ KAsync::Job<qint64> CommandProcessor::processQueuedCommand(const QByteArray &dat
227KAsync::Job<void> CommandProcessor::processQueue(MessageQueue *queue) 227KAsync::Job<void> CommandProcessor::processQueue(MessageQueue *queue)
228{ 228{
229 auto time = QSharedPointer<QTime>::create(); 229 auto time = QSharedPointer<QTime>::create();
230 return KAsync::syncStart<void>([this]() { mPipeline->startTransaction(); }) 230 return KAsync::start([this]() { mPipeline->startTransaction(); })
231 .then(KAsync::doWhile( 231 .then(KAsync::doWhile(
232 [this, queue, time]() -> KAsync::Job<KAsync::ControlFlowFlag> { 232 [this, queue, time]() -> KAsync::Job<KAsync::ControlFlowFlag> {
233 return queue->dequeueBatch(sBatchSize, 233 return queue->dequeueBatch(sBatchSize,