diff options
| author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-01-12 11:45:15 +0100 |
|---|---|---|
| committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-01-12 11:45:15 +0100 |
| commit | 7daeec83233c522980d5e477fee82045de57f77d (patch) | |
| tree | 5e03d11d23c764eb03f27393fcc37c0529405e10 /common/messagequeue.cpp | |
| parent | af8baff21529b5bc47725da3e9e00ec81e5b6f1b (diff) | |
| download | sink-7daeec83233c522980d5e477fee82045de57f77d.tar.gz sink-7daeec83233c522980d5e477fee82045de57f77d.zip | |
syncThen is no longer necessary
Diffstat (limited to 'common/messagequeue.cpp')
| -rw-r--r-- | common/messagequeue.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/common/messagequeue.cpp b/common/messagequeue.cpp index 0fcbf99..6e79d89 100644 --- a/common/messagequeue.cpp +++ b/common/messagequeue.cpp | |||
| @@ -108,7 +108,7 @@ KAsync::Job<void> MessageQueue::dequeueBatch(int maxBatchSize, const std::functi | |||
| 108 | 108 | ||
| 109 | // Trace() << "Waiting on " << waitCondition.size() << " results"; | 109 | // Trace() << "Waiting on " << waitCondition.size() << " results"; |
| 110 | KAsync::waitForCompletion(waitCondition) | 110 | KAsync::waitForCompletion(waitCondition) |
| 111 | .syncThen<void>([this, resultCount, &future]() { | 111 | .then([this, resultCount, &future]() { |
| 112 | processRemovals(); | 112 | processRemovals(); |
| 113 | if (*resultCount == 0) { | 113 | if (*resultCount == 0) { |
| 114 | future.setFinished(); | 114 | future.setFinished(); |