diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-01-18 15:55:28 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-01-18 15:55:28 +0100 |
commit | 47412280397d66950abd9582048ce8e465fc2844 (patch) | |
tree | ba4cbea4d2baaee01e33154a4335ade1d0b02370 /common/synchronizer.cpp | |
parent | efe439ae932d221816f5c24283022d494bcb9796 (diff) | |
download | sink-47412280397d66950abd9582048ce8e465fc2844.tar.gz sink-47412280397d66950abd9582048ce8e465fc2844.zip |
Don't overwrite the first job with the continuation
Diffstat (limited to 'common/synchronizer.cpp')
-rw-r--r-- | common/synchronizer.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/common/synchronizer.cpp b/common/synchronizer.cpp index cfd2c10..d86b027 100644 --- a/common/synchronizer.cpp +++ b/common/synchronizer.cpp | |||
@@ -336,7 +336,7 @@ KAsync::Job<void> Synchronizer::processSyncQueue() | |||
336 | enqueueCommand(Sink::Commands::FlushCommand, BufferUtils::extractBuffer(fbb)); | 336 | enqueueCommand(Sink::Commands::FlushCommand, BufferUtils::extractBuffer(fbb)); |
337 | } | 337 | } |
338 | } else if (request.requestType == Synchronizer::SyncRequest::ChangeReplay) { | 338 | } else if (request.requestType == Synchronizer::SyncRequest::ChangeReplay) { |
339 | job = replayNextRevision(); | 339 | job = job.then(replayNextRevision()); |
340 | } else { | 340 | } else { |
341 | SinkWarning() << "Unknown request type: " << request.requestType; | 341 | SinkWarning() << "Unknown request type: " << request.requestType; |
342 | return KAsync::error(KAsync::Error{"Unknown request type."}); | 342 | return KAsync::error(KAsync::Error{"Unknown request type."}); |