From 81b459c0f013704e95fb5933525c82a6ca46f13f Mon Sep 17 00:00:00 2001
From: Christian Mollekopf <chrigi_1@fastmail.fm>
Date: Tue, 29 Nov 2016 00:24:04 +0100
Subject: Cleanup

---
 common/commandprocessor.cpp | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

(limited to 'common/commandprocessor.cpp')

diff --git a/common/commandprocessor.cpp b/common/commandprocessor.cpp
index bdff905..fccff22 100644
--- a/common/commandprocessor.cpp
+++ b/common/commandprocessor.cpp
@@ -122,15 +122,14 @@ void CommandProcessor::processSynchronizeCommand(const QByteArray &data)
         auto buffer = Sink::Commands::GetSynchronize(data.constData());
         auto timer = QSharedPointer<QTime>::create();
         timer->start();
-        auto job = KAsync::null<void>();
         Sink::QueryBase query;
         if (buffer->query()) {
             auto data = QByteArray::fromStdString(buffer->query()->str());
             QDataStream stream(&data, QIODevice::ReadOnly);
             stream >> query;
         }
-        job = synchronizeWithSource(query);
-        job.then<void>([timer](const KAsync::Error &error) {
+        synchronizeWithSource(query)
+            .then<void>([timer](const KAsync::Error &error) {
                 if (error) {
                     SinkWarning() << "Sync failed: " << error.errorMessage;
                     return KAsync::error(error);
@@ -140,7 +139,6 @@ void CommandProcessor::processSynchronizeCommand(const QByteArray &data)
                 }
             })
             .exec();
-        return;
     } else {
         SinkWarning() << "received invalid command";
     }
-- 
cgit v1.2.3