From 7daeec83233c522980d5e477fee82045de57f77d Mon Sep 17 00:00:00 2001 From: Christian Mollekopf Date: Thu, 12 Jan 2017 11:45:15 +0100 Subject: syncThen is no longer necessary --- common/synchronizer.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'common/synchronizer.cpp') diff --git a/common/synchronizer.cpp b/common/synchronizer.cpp index a4e64c9..bb1a3f4 100644 --- a/common/synchronizer.cpp +++ b/common/synchronizer.cpp @@ -286,7 +286,7 @@ KAsync::Job Synchronizer::processSyncQueue() while (!mSyncRequestQueue.isEmpty()) { auto request = mSyncRequestQueue.takeFirst(); if (request.requestType == Synchronizer::SyncRequest::Synchronization) { - job = job.syncThen([this, request] { + job = job.then([this, request] { Sink::Notification n; n.id = request.requestId; n.type = Notification::Status; @@ -294,7 +294,7 @@ KAsync::Job Synchronizer::processSyncQueue() n.code = ApplicationDomain::BusyStatus; emit notify(n); SinkLogCtx(mLogCtx) << "Synchronizing " << request.query; - }).then(synchronizeWithSource(request.query)).syncThen([this] { + }).then(synchronizeWithSource(request.query)).then([this] { //Commit after every request, so implementations only have to commit more if they add a lot of data. commit(); }).then([this, request](const KAsync::Error &error) { @@ -431,7 +431,7 @@ KAsync::Job Synchronizer::replay(const QByteArray &type, const QByteArray job = replay(mail, operation, oldRemoteId, modifiedProperties); } - return job.syncThen([this, operation, type, uid, oldRemoteId](const QByteArray &remoteId) { + return job.then([this, operation, type, uid, oldRemoteId](const QByteArray &remoteId) { if (operation == Sink::Operation_Creation) { SinkTrace() << "Replayed creation with remote id: " << remoteId; if (remoteId.isEmpty()) { @@ -453,7 +453,7 @@ KAsync::Job Synchronizer::replay(const QByteArray &type, const QByteArray SinkError() << "Unkown operation" << operation; } }) - .syncThen([this](const KAsync::Error &error) { + .then([this](const KAsync::Error &error) { if (error) { SinkWarning() << "Failed to replay change: " << error.errorMessage; } -- cgit v1.2.3