diff options
| author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-03-02 12:27:09 +0100 |
|---|---|---|
| committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-03-02 12:27:09 +0100 |
| commit | be652c12dfa5162d952f5226de453e1a29957c3a (patch) | |
| tree | 9f54e2daab45a08d54e9ec8fec798b8f968988ed /common/commandprocessor.cpp | |
| parent | 60cb0a4607e8fe0317920d7c3d110f508186859e (diff) | |
| download | sink-be652c12dfa5162d952f5226de453e1a29957c3a.tar.gz sink-be652c12dfa5162d952f5226de453e1a29957c3a.zip | |
Port away from syncStartv0.1.0
Diffstat (limited to 'common/commandprocessor.cpp')
| -rw-r--r-- | common/commandprocessor.cpp | 2 |
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 | |||
| 227 | KAsync::Job<void> CommandProcessor::processQueue(MessageQueue *queue) | 227 | KAsync::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, |