summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--common/queryrunner.cpp3
-rw-r--r--common/resourcecontrol.cpp8
-rw-r--r--common/store.cpp4
-rw-r--r--tests/maildirresourcetest.cpp4
4 files changed, 5 insertions, 14 deletions
diff --git a/common/queryrunner.cpp b/common/queryrunner.cpp
index 4d05721..22682d3 100644
--- a/common/queryrunner.cpp
+++ b/common/queryrunner.cpp
@@ -105,8 +105,7 @@ QueryRunner<DomainType>::QueryRunner(const Sink::Query &query, const Sink::Resou
105 .template then<void, qint64>([query, this](qint64 newRevision) { 105 .template then<void, qint64>([query, this](qint64 newRevision) {
106 //Only send the revision replayed information if we're connected to the resource, there's no need to start the resource otherwise. 106 //Only send the revision replayed information if we're connected to the resource, there's no need to start the resource otherwise.
107 mResourceAccess->sendRevisionReplayedCommand(newRevision); 107 mResourceAccess->sendRevisionReplayedCommand(newRevision);
108 }) 108 });
109 .template then<void>([](){});
110 }); 109 });
111 //Ensure the connection is open, if it wasn't already opened 110 //Ensure the connection is open, if it wasn't already opened
112 //TODO If we are not connected already, we have to check for the latest revision once connected, otherwise we could miss some updates 111 //TODO If we are not connected already, we have to check for the latest revision once connected, otherwise we could miss some updates
diff --git a/common/resourcecontrol.cpp b/common/resourcecontrol.cpp
index 4a6f9b4..83558bd 100644
--- a/common/resourcecontrol.cpp
+++ b/common/resourcecontrol.cpp
@@ -53,9 +53,7 @@ KAsync::Job<void> ResourceControl::shutdown(const QByteArray &identifier)
53 [](int, const QString &) { 53 [](int, const QString &) {
54 Trace() << "Resource is already closed."; 54 Trace() << "Resource is already closed.";
55 //Resource isn't started, nothing to shutdown 55 //Resource isn't started, nothing to shutdown
56 }) 56 });
57 //FIXME JOBAPI this is only required because we don't care about the return value of connectToServer
58 .template then<void>([](){});
59} 57}
60 58
61KAsync::Job<void> ResourceControl::start(const QByteArray &identifier) 59KAsync::Job<void> ResourceControl::start(const QByteArray &identifier)
@@ -81,9 +79,7 @@ KAsync::Job<void> ResourceControl::flushMessageQueue(const QByteArrayList &resou
81 resourceAccess->synchronizeResource(false, true).then<void>([&future, resourceAccess]() { 79 resourceAccess->synchronizeResource(false, true).then<void>([&future, resourceAccess]() {
82 future.setFinished(); 80 future.setFinished();
83 }).exec(); 81 }).exec();
84 }) 82 });
85 //FIXME JOBAPI this is only required because we don't care about the return value of each (and each shouldn't even have a return value)
86 .template then<void>([](){});
87} 83}
88 84
89KAsync::Job<void> ResourceControl::flushReplayQueue(const QByteArrayList &resourceIdentifier) 85KAsync::Job<void> ResourceControl::flushReplayQueue(const QByteArrayList &resourceIdentifier)
diff --git a/common/store.cpp b/common/store.cpp
index 7f93202..6f080b5 100644
--- a/common/store.cpp
+++ b/common/store.cpp
@@ -176,9 +176,7 @@ KAsync::Job<void> Store::synchronize(const Sink::Query &query)
176 resourceAccess->synchronizeResource(true, false).then<void>([&future, resourceAccess]() { 176 resourceAccess->synchronizeResource(true, false).then<void>([&future, resourceAccess]() {
177 future.setFinished(); 177 future.setFinished();
178 }).exec(); 178 }).exec();
179 }) 179 });
180 //FIXME JOBAPI this is only required because we don't care about the return value of each (and each shouldn't even have a return value)
181 .template then<void>([](){});
182} 180}
183 181
184template <class DomainType> 182template <class DomainType>
diff --git a/tests/maildirresourcetest.cpp b/tests/maildirresourcetest.cpp
index d47a3ac..28a1d44 100644
--- a/tests/maildirresourcetest.cpp
+++ b/tests/maildirresourcetest.cpp
@@ -329,7 +329,6 @@ private Q_SLOTS:
329 .then(ResourceControl::flushReplayQueue(query.resources)) //The change needs to be replayed already 329 .then(ResourceControl::flushReplayQueue(query.resources)) //The change needs to be replayed already
330 .then(ResourceControl::inspect<Mail>(ResourceControl::Inspection::ExistenceInspection(*mail, false))); 330 .then(ResourceControl::inspect<Mail>(ResourceControl::Inspection::ExistenceInspection(*mail, false)));
331 }); 331 });
332 // .then<void>([](){});
333 }) 332 })
334 .exec(); 333 .exec();
335 result.waitForFinished(); 334 result.waitForFinished();
@@ -366,8 +365,7 @@ private Q_SLOTS:
366 .then<void>(ResourceControl::flushReplayQueue(query.resources)) //The change needs to be replayed already 365 .then<void>(ResourceControl::flushReplayQueue(query.resources)) //The change needs to be replayed already
367 .then(ResourceControl::inspect<Mail>(ResourceControl::Inspection::PropertyInspection(*mail, "unread", true))) 366 .then(ResourceControl::inspect<Mail>(ResourceControl::Inspection::PropertyInspection(*mail, "unread", true)))
368 .then(ResourceControl::inspect<Mail>(ResourceControl::Inspection::PropertyInspection(*mail, "subject", mail->getProperty("subject")))); 367 .then(ResourceControl::inspect<Mail>(ResourceControl::Inspection::PropertyInspection(*mail, "subject", mail->getProperty("subject"))));
369 }) 368 });
370 .then<void>([](){});
371 }) 369 })
372 .exec(); 370 .exec();
373 result.waitForFinished(); 371 result.waitForFinished();