diff options
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(); |