diff options
| author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-07-27 13:12:22 +0200 |
|---|---|---|
| committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-09-15 16:14:19 +0200 |
| commit | 16e63edbc38fca44800df6e9125e1dfc231df1cd (patch) | |
| tree | 43e64098fb8b0662819260f4eb21bcedf65b97bf /common/messagequeue.cpp | |
| parent | 26816c21f60450e461a5b6ef4ef740f6070ce278 (diff) | |
| download | sink-16e63edbc38fca44800df6e9125e1dfc231df1cd.tar.gz sink-16e63edbc38fca44800df6e9125e1dfc231df1cd.zip | |
This is not an error according to the tests
Diffstat (limited to 'common/messagequeue.cpp')
| -rw-r--r-- | common/messagequeue.cpp | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/common/messagequeue.cpp b/common/messagequeue.cpp index 28eacb7..54aaf8c 100644 --- a/common/messagequeue.cpp +++ b/common/messagequeue.cpp | |||
| @@ -108,7 +108,6 @@ KAsync::Job<void> MessageQueue::dequeueBatch(int maxBatchSize, const std::functi | |||
| 108 | .syncThen<void>([this, resultCount, &future]() { | 108 | .syncThen<void>([this, resultCount, &future]() { |
| 109 | processRemovals(); | 109 | processRemovals(); |
| 110 | if (*resultCount == 0) { | 110 | if (*resultCount == 0) { |
| 111 | future.setError(static_cast<int>(ErrorCodes::NoMessageFound), "No message found"); | ||
| 112 | future.setFinished(); | 111 | future.setFinished(); |
| 113 | } else { | 112 | } else { |
| 114 | if (isEmpty()) { | 113 | if (isEmpty()) { |