diff options
| author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-12-12 15:17:32 +0100 |
|---|---|---|
| committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-12-12 15:17:32 +0100 |
| commit | eb6e9229c8cecd4b573039fafd644a16912e31f6 (patch) | |
| tree | 7d4b65e49c5e92d2998e0066d4f0dc71ee906e64 /common/changereplay.cpp | |
| parent | c67c99d11fc012404f2fbd8fa3b27fac675ce9f2 (diff) | |
| download | sink-eb6e9229c8cecd4b573039fafd644a16912e31f6.tar.gz sink-eb6e9229c8cecd4b573039fafd644a16912e31f6.zip | |
Adapt to kasync changes
Diffstat (limited to 'common/changereplay.cpp')
| -rw-r--r-- | common/changereplay.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/common/changereplay.cpp b/common/changereplay.cpp index 13ed49e..5d5afbb 100644 --- a/common/changereplay.cpp +++ b/common/changereplay.cpp | |||
| @@ -92,7 +92,7 @@ KAsync::Job<void> ChangeReplay::replayNextRevision() | |||
| 92 | *topRevision = DataStore::maxRevision(mMainStoreTransaction); | 92 | *topRevision = DataStore::maxRevision(mMainStoreTransaction); |
| 93 | SinkTrace() << "Changereplay from " << *lastReplayedRevision << " to " << *topRevision; | 93 | SinkTrace() << "Changereplay from " << *lastReplayedRevision << " to " << *topRevision; |
| 94 | }) | 94 | }) |
| 95 | .then(KAsync::dowhile( | 95 | .then(KAsync::doWhile( |
| 96 | [this, lastReplayedRevision, topRevision]() -> KAsync::Job<KAsync::ControlFlowFlag> { | 96 | [this, lastReplayedRevision, topRevision]() -> KAsync::Job<KAsync::ControlFlowFlag> { |
| 97 | if (*lastReplayedRevision >= *topRevision) { | 97 | if (*lastReplayedRevision >= *topRevision) { |
| 98 | return KAsync::value(KAsync::Break); | 98 | return KAsync::value(KAsync::Break); |