summaryrefslogtreecommitdiffstats
path: root/tests
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2017-01-12 11:45:15 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2017-01-12 11:45:15 +0100
commit7daeec83233c522980d5e477fee82045de57f77d (patch)
tree5e03d11d23c764eb03f27393fcc37c0529405e10 /tests
parentaf8baff21529b5bc47725da3e9e00ec81e5b6f1b (diff)
downloadsink-7daeec83233c522980d5e477fee82045de57f77d.tar.gz
sink-7daeec83233c522980d5e477fee82045de57f77d.zip
syncThen is no longer necessary
Diffstat (limited to 'tests')
-rw-r--r--tests/accountstest.cpp8
-rw-r--r--tests/clientapitest.cpp2
-rw-r--r--tests/mailsynctest.cpp28
-rw-r--r--tests/mailtest.cpp18
-rw-r--r--tests/mailthreadtest.cpp2
-rw-r--r--tests/resourcecommunicationtest.cpp6
6 files changed, 32 insertions, 32 deletions
diff --git a/tests/accountstest.cpp b/tests/accountstest.cpp
index cce5c7b..0ab18ef 100644
--- a/tests/accountstest.cpp
+++ b/tests/accountstest.cpp
@@ -39,7 +39,7 @@ private slots:
39 account.setIcon(accountIcon); 39 account.setIcon(accountIcon);
40 Store::create(account).exec().waitForFinished(); 40 Store::create(account).exec().waitForFinished();
41 41
42 Store::fetchAll<SinkAccount>(Query()).syncThen<void, QList<SinkAccount::Ptr>>([&](const QList<SinkAccount::Ptr> &accounts) { 42 Store::fetchAll<SinkAccount>(Query()).then([&](const QList<SinkAccount::Ptr> &accounts) {
43 QCOMPARE(accounts.size(), 1); 43 QCOMPARE(accounts.size(), 1);
44 auto account = accounts.first(); 44 auto account = accounts.first();
45 QCOMPARE(account->getAccountType(), QString("maildir")); 45 QCOMPARE(account->getAccountType(), QString("maildir"));
@@ -60,7 +60,7 @@ private slots:
60 Store::create(resource).exec().waitForFinished(); 60 Store::create(resource).exec().waitForFinished();
61 61
62 62
63 Store::fetchAll<SinkResource>(Query()).syncThen<void, QList<SinkResource::Ptr>>([&](const QList<SinkResource::Ptr> &resources) { 63 Store::fetchAll<SinkResource>(Query()).then([&](const QList<SinkResource::Ptr> &resources) {
64 QCOMPARE(resources.size(), 1); 64 QCOMPARE(resources.size(), 1);
65 auto resource = resources.first(); 65 auto resource = resources.first();
66 QCOMPARE(resource->getResourceType(), QByteArray("sink.mailtransport")); 66 QCOMPARE(resource->getResourceType(), QByteArray("sink.mailtransport"));
@@ -74,7 +74,7 @@ private slots:
74 identity.setAccount(account.identifier()); 74 identity.setAccount(account.identifier());
75 Store::create(identity).exec().waitForFinished(); 75 Store::create(identity).exec().waitForFinished();
76 76
77 Store::fetchAll<Identity>(Query()).syncThen<void, QList<Identity::Ptr>>([&](const QList<Identity::Ptr> &identities) { 77 Store::fetchAll<Identity>(Query()).then([&](const QList<Identity::Ptr> &identities) {
78 QCOMPARE(identities.size(), 1); 78 QCOMPARE(identities.size(), 1);
79 QCOMPARE(identities.first()->getName(), smtpServer); 79 QCOMPARE(identities.first()->getName(), smtpServer);
80 QCOMPARE(identities.first()->getAddress(), smtpUsername); 80 QCOMPARE(identities.first()->getAddress(), smtpUsername);
@@ -85,7 +85,7 @@ private slots:
85 85
86 Store::remove(resource).exec().waitForFinished(); 86 Store::remove(resource).exec().waitForFinished();
87 87
88 Store::fetchAll<SinkResource>(Query()).syncThen<void, QList<SinkResource::Ptr>>([](const QList<SinkResource::Ptr> &resources) { 88 Store::fetchAll<SinkResource>(Query()).then([](const QList<SinkResource::Ptr> &resources) {
89 QCOMPARE(resources.size(), 0); 89 QCOMPARE(resources.size(), 0);
90 }) 90 })
91 .exec().waitForFinished(); 91 .exec().waitForFinished();
diff --git a/tests/clientapitest.cpp b/tests/clientapitest.cpp
index 544b981..8fc76df 100644
--- a/tests/clientapitest.cpp
+++ b/tests/clientapitest.cpp
@@ -276,7 +276,7 @@ private slots:
276 276
277 bool gotValue = false; 277 bool gotValue = false;
278 auto result = Sink::Store::fetchOne<Sink::ApplicationDomain::Event>(query) 278 auto result = Sink::Store::fetchOne<Sink::ApplicationDomain::Event>(query)
279 .syncThen<void, Sink::ApplicationDomain::Event>([&gotValue](const Sink::ApplicationDomain::Event &event) { gotValue = true; }) 279 .then([&gotValue](const Sink::ApplicationDomain::Event &event) { gotValue = true; })
280 .exec(); 280 .exec();
281 result.waitForFinished(); 281 result.waitForFinished();
282 QVERIFY(!result.errorCode()); 282 QVERIFY(!result.errorCode());
diff --git a/tests/mailsynctest.cpp b/tests/mailsynctest.cpp
index 96a2daa..d3b0fe3 100644
--- a/tests/mailsynctest.cpp
+++ b/tests/mailsynctest.cpp
@@ -68,7 +68,7 @@ void MailSyncTest::testListFolders()
68 //First figure out how many folders we have by default 68 //First figure out how many folders we have by default
69 { 69 {
70 auto job = Store::fetchAll<Folder>(Query()) 70 auto job = Store::fetchAll<Folder>(Query())
71 .syncThen<void, QList<Folder::Ptr>>([&](const QList<Folder::Ptr> &folders) { 71 .then([&](const QList<Folder::Ptr> &folders) {
72 QStringList names; 72 QStringList names;
73 for (const auto &folder : folders) { 73 for (const auto &folder : folders) {
74 names << folder->getName(); 74 names << folder->getName();
@@ -87,7 +87,7 @@ void MailSyncTest::testListFolders()
87 VERIFYEXEC(Store::synchronize(query)); 87 VERIFYEXEC(Store::synchronize(query));
88 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 88 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
89 89
90 auto job = Store::fetchAll<Folder>(query).syncThen<void, QList<Folder::Ptr>>([=](const QList<Folder::Ptr> &folders) { 90 auto job = Store::fetchAll<Folder>(query).then([=](const QList<Folder::Ptr> &folders) {
91 QStringList names; 91 QStringList names;
92 QHash<QByteArray, QByteArray> specialPurposeFolders; 92 QHash<QByteArray, QByteArray> specialPurposeFolders;
93 for (const auto &folder : folders) { 93 for (const auto &folder : folders) {
@@ -128,7 +128,7 @@ void MailSyncTest::testListNewFolder()
128 VERIFYEXEC(Store::synchronize(query)); 128 VERIFYEXEC(Store::synchronize(query));
129 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 129 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
130 130
131 auto job = Store::fetchAll<Folder>(query).syncThen<void, QList<Folder::Ptr>>([](const QList<Folder::Ptr> &folders) { 131 auto job = Store::fetchAll<Folder>(query).then([](const QList<Folder::Ptr> &folders) {
132 QStringList names; 132 QStringList names;
133 for (const auto &folder : folders) { 133 for (const auto &folder : folders) {
134 names << folder->getName(); 134 names << folder->getName();
@@ -153,7 +153,7 @@ void MailSyncTest::testListRemovedFolder()
153 VERIFYEXEC(Store::synchronize(query)); 153 VERIFYEXEC(Store::synchronize(query));
154 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 154 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
155 155
156 auto job = Store::fetchAll<Folder>(query).syncThen<void, QList<Folder::Ptr>>([](const QList<Folder::Ptr> &folders) { 156 auto job = Store::fetchAll<Folder>(query).then([](const QList<Folder::Ptr> &folders) {
157 QStringList names; 157 QStringList names;
158 for (const auto &folder : folders) { 158 for (const auto &folder : folders) {
159 names << folder->getName(); 159 names << folder->getName();
@@ -178,7 +178,7 @@ void MailSyncTest::testListFolderHierarchy()
178 VERIFYEXEC(Store::synchronize(query)); 178 VERIFYEXEC(Store::synchronize(query));
179 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 179 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
180 180
181 auto job = Store::fetchAll<Folder>(query).syncThen<void, QList<Folder::Ptr>>([=](const QList<Folder::Ptr> &folders) { 181 auto job = Store::fetchAll<Folder>(query).then([=](const QList<Folder::Ptr> &folders) {
182 QHash<QString, Folder::Ptr> map; 182 QHash<QString, Folder::Ptr> map;
183 for (const auto &folder : folders) { 183 for (const auto &folder : folders) {
184 map.insert(folder->getName(), folder); 184 map.insert(folder->getName(), folder);
@@ -221,7 +221,7 @@ void MailSyncTest::testListNewSubFolder()
221 VERIFYEXEC(Store::synchronize(query)); 221 VERIFYEXEC(Store::synchronize(query));
222 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 222 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
223 223
224 auto job = Store::fetchAll<Folder>(query).syncThen<void, QList<Folder::Ptr>>([](const QList<Folder::Ptr> &folders) { 224 auto job = Store::fetchAll<Folder>(query).then([](const QList<Folder::Ptr> &folders) {
225 QStringList names; 225 QStringList names;
226 for (const auto &folder : folders) { 226 for (const auto &folder : folders) {
227 names << folder->getName(); 227 names << folder->getName();
@@ -249,7 +249,7 @@ void MailSyncTest::testListRemovedSubFolder()
249 VERIFYEXEC(Store::synchronize(query)); 249 VERIFYEXEC(Store::synchronize(query));
250 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 250 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
251 251
252 auto job = Store::fetchAll<Folder>(query).syncThen<void, QList<Folder::Ptr>>([](const QList<Folder::Ptr> &folders) { 252 auto job = Store::fetchAll<Folder>(query).then([](const QList<Folder::Ptr> &folders) {
253 QStringList names; 253 QStringList names;
254 for (const auto &folder : folders) { 254 for (const auto &folder : folders) {
255 names << folder->getName(); 255 names << folder->getName();
@@ -269,7 +269,7 @@ void MailSyncTest::testListMails()
269 VERIFYEXEC(Store::synchronize(query)); 269 VERIFYEXEC(Store::synchronize(query));
270 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 270 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
271 271
272 auto job = Store::fetchAll<Mail>(query).syncThen<void, QList<Mail::Ptr>>([](const QList<Mail::Ptr> &mails) { 272 auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) {
273 QCOMPARE(mails.size(), 1); 273 QCOMPARE(mails.size(), 1);
274 QVERIFY(mails.first()->getSubject().startsWith(QString("[Nepomuk] Jenkins build is still unstable"))); 274 QVERIFY(mails.first()->getSubject().startsWith(QString("[Nepomuk] Jenkins build is still unstable")));
275 const auto data = mails.first()->getMimeMessage(); 275 const auto data = mails.first()->getMimeMessage();
@@ -298,7 +298,7 @@ void MailSyncTest::testResyncMails()
298 VERIFYEXEC(Store::synchronize(query)); 298 VERIFYEXEC(Store::synchronize(query));
299 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 299 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
300 300
301 auto job = Store::fetchAll<Mail>(query).syncThen<void, QList<Mail::Ptr>>([](const QList<Mail::Ptr> &mails) { 301 auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) {
302 QCOMPARE(mails.size(), 1); 302 QCOMPARE(mails.size(), 1);
303 }); 303 });
304 VERIFYEXEC(job); 304 VERIFYEXEC(job);
@@ -323,7 +323,7 @@ void MailSyncTest::testFetchNewRemovedMessages()
323 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 323 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
324 324
325 { 325 {
326 auto job = Store::fetchAll<Mail>(query).syncThen<void, QList<Mail::Ptr>>([](const QList<Mail::Ptr> &mails) { 326 auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) {
327 QCOMPARE(mails.size(), 2); 327 QCOMPARE(mails.size(), 2);
328 }); 328 });
329 VERIFYEXEC(job); 329 VERIFYEXEC(job);
@@ -335,7 +335,7 @@ void MailSyncTest::testFetchNewRemovedMessages()
335 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 335 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
336 336
337 { 337 {
338 auto job = Store::fetchAll<Mail>(query).syncThen<void, QList<Mail::Ptr>>([](const QList<Mail::Ptr> &mails) { 338 auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) {
339 QCOMPARE(mails.size(), 1); 339 QCOMPARE(mails.size(), 1);
340 }); 340 });
341 VERIFYEXEC(job); 341 VERIFYEXEC(job);
@@ -358,7 +358,7 @@ void MailSyncTest::testFlagChange()
358 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 358 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
359 359
360 { 360 {
361 auto job = Store::fetchAll<Mail>(query).syncThen<void, QList<Mail::Ptr>>([](const QList<Mail::Ptr> &mails) { 361 auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) {
362 QCOMPARE(mails.size(), 0); 362 QCOMPARE(mails.size(), 0);
363 }); 363 });
364 VERIFYEXEC(job); 364 VERIFYEXEC(job);
@@ -371,7 +371,7 @@ void MailSyncTest::testFlagChange()
371 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 371 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
372 372
373 { 373 {
374 auto job = Store::fetchAll<Mail>(query).syncThen<void, QList<Mail::Ptr>>([](const QList<Mail::Ptr> &mails) { 374 auto job = Store::fetchAll<Mail>(query).then([](const QList<Mail::Ptr> &mails) {
375 QCOMPARE(mails.size(), 1); 375 QCOMPARE(mails.size(), 1);
376 QVERIFY(mails.first()->getImportant()); 376 QVERIFY(mails.first()->getImportant());
377 }); 377 });
@@ -387,7 +387,7 @@ void MailSyncTest::testSyncSingleFolder()
387 387
388 Folder::Ptr folder; 388 Folder::Ptr folder;
389 { 389 {
390 auto job = Store::fetchAll<Folder>(Sink::Query{}.resourceFilter(mResourceInstanceIdentifier).filter<Folder::Name>("test")).template syncThen<void, QList<Folder::Ptr>>([&](const QList<Folder::Ptr> &folders) { 390 auto job = Store::fetchAll<Folder>(Sink::Query{}.resourceFilter(mResourceInstanceIdentifier).filter<Folder::Name>("test")).template then([&](const QList<Folder::Ptr> &folders) {
391 QCOMPARE(folders.size(), 1); 391 QCOMPARE(folders.size(), 1);
392 folder = folders.first(); 392 folder = folders.first();
393 }); 393 });
diff --git a/tests/mailtest.cpp b/tests/mailtest.cpp
index fe28cde..c51fc56 100644
--- a/tests/mailtest.cpp
+++ b/tests/mailtest.cpp
@@ -67,7 +67,7 @@ void MailTest::testCreateModifyDeleteFolder()
67 //First figure out how many folders we have by default 67 //First figure out how many folders we have by default
68 { 68 {
69 auto job = Store::fetchAll<Folder>(Query()) 69 auto job = Store::fetchAll<Folder>(Query())
70 .syncThen<void, QList<Folder::Ptr>>([&](const QList<Folder::Ptr> &folders) { 70 .then([&](const QList<Folder::Ptr> &folders) {
71 baseCount = folders.size(); 71 baseCount = folders.size();
72 }); 72 });
73 VERIFYEXEC(job); 73 VERIFYEXEC(job);
@@ -84,7 +84,7 @@ void MailTest::testCreateModifyDeleteFolder()
84 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 84 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
85 { 85 {
86 auto job = Store::fetchAll<Folder>(Query().request<Folder::Name>().request<Folder::Icon>()) 86 auto job = Store::fetchAll<Folder>(Query().request<Folder::Name>().request<Folder::Icon>())
87 .syncThen<void, QList<Folder::Ptr>>([=](const QList<Folder::Ptr> &folders) { 87 .then([=](const QList<Folder::Ptr> &folders) {
88 QCOMPARE(folders.size(), baseCount + 1); 88 QCOMPARE(folders.size(), baseCount + 1);
89 QHash<QString, Folder::Ptr> foldersByName; 89 QHash<QString, Folder::Ptr> foldersByName;
90 for (const auto &folder : folders) { 90 for (const auto &folder : folders) {
@@ -110,7 +110,7 @@ void MailTest::testCreateModifyDeleteFolder()
110 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 110 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
111 { 111 {
112 auto job = Store::fetchAll<Folder>(Query().request<Folder::Name>().request<Folder::Icon>()) 112 auto job = Store::fetchAll<Folder>(Query().request<Folder::Name>().request<Folder::Icon>())
113 .syncThen<void, QList<Folder::Ptr>>([=](const QList<Folder::Ptr> &folders) { 113 .then([=](const QList<Folder::Ptr> &folders) {
114 QCOMPARE(folders.size(), baseCount + 1); 114 QCOMPARE(folders.size(), baseCount + 1);
115 QHash<QString, Folder::Ptr> foldersByName; 115 QHash<QString, Folder::Ptr> foldersByName;
116 for (const auto &folder : folders) { 116 for (const auto &folder : folders) {
@@ -131,7 +131,7 @@ void MailTest::testCreateModifyDeleteFolder()
131 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 131 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
132 { 132 {
133 auto job = Store::fetchAll<Folder>(Query().request<Folder::Name>().request<Folder::Icon>()) 133 auto job = Store::fetchAll<Folder>(Query().request<Folder::Name>().request<Folder::Icon>())
134 .syncThen<void, QList<Folder::Ptr>>([=](const QList<Folder::Ptr> &folders) { 134 .then([=](const QList<Folder::Ptr> &folders) {
135 QCOMPARE(folders.size(), baseCount); 135 QCOMPARE(folders.size(), baseCount);
136 }); 136 });
137 VERIFYEXEC(job); 137 VERIFYEXEC(job);
@@ -161,7 +161,7 @@ void MailTest::testCreateModifyDeleteMail()
161 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 161 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
162 { 162 {
163 auto job = Store::fetchAll<Mail>(Query().request<Mail::Folder>().request<Mail::Subject>().request<Mail::MimeMessage>()) 163 auto job = Store::fetchAll<Mail>(Query().request<Mail::Folder>().request<Mail::Subject>().request<Mail::MimeMessage>())
164 .syncThen<void, QList<Mail::Ptr>>([=](const QList<Mail::Ptr> &mails) { 164 .then([=](const QList<Mail::Ptr> &mails) {
165 QCOMPARE(mails.size(), 1); 165 QCOMPARE(mails.size(), 1);
166 auto mail = *mails.first(); 166 auto mail = *mails.first();
167 QCOMPARE(mail.getSubject(), subject); 167 QCOMPARE(mail.getSubject(), subject);
@@ -190,7 +190,7 @@ void MailTest::testCreateModifyDeleteMail()
190 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 190 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
191 { 191 {
192 auto job = Store::fetchAll<Mail>(Query().request<Mail::Folder>().request<Mail::Subject>().request<Mail::MimeMessage>()) 192 auto job = Store::fetchAll<Mail>(Query().request<Mail::Folder>().request<Mail::Subject>().request<Mail::MimeMessage>())
193 .syncThen<void, QList<Mail::Ptr>>([=](const QList<Mail::Ptr> &mails) { 193 .then([=](const QList<Mail::Ptr> &mails) {
194 QCOMPARE(mails.size(), 1); 194 QCOMPARE(mails.size(), 1);
195 auto mail = *mails.first(); 195 auto mail = *mails.first();
196 QCOMPARE(mail.getSubject(), subject2); 196 QCOMPARE(mail.getSubject(), subject2);
@@ -212,7 +212,7 @@ void MailTest::testCreateModifyDeleteMail()
212 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 212 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
213 { 213 {
214 auto job = Store::fetchAll<Mail>(Query().request<Mail::Folder>().request<Mail::Subject>()) 214 auto job = Store::fetchAll<Mail>(Query().request<Mail::Folder>().request<Mail::Subject>())
215 .syncThen<void, QList<Mail::Ptr>>([=](const QList<Mail::Ptr> &mails) { 215 .then([=](const QList<Mail::Ptr> &mails) {
216 QCOMPARE(mails.size(), 0); 216 QCOMPARE(mails.size(), 0);
217 }); 217 });
218 VERIFYEXEC(job); 218 VERIFYEXEC(job);
@@ -248,7 +248,7 @@ void MailTest::testMoveMail()
248 Mail modifiedMail; 248 Mail modifiedMail;
249 { 249 {
250 auto job = Store::fetchAll<Mail>(Query().request<Mail::Folder>().request<Mail::Subject>().request<Mail::MimeMessage>()) 250 auto job = Store::fetchAll<Mail>(Query().request<Mail::Folder>().request<Mail::Subject>().request<Mail::MimeMessage>())
251 .syncThen<void, QList<Mail::Ptr>>([=, &modifiedMail](const QList<Mail::Ptr> &mails) { 251 .then([=, &modifiedMail](const QList<Mail::Ptr> &mails) {
252 QCOMPARE(mails.size(), 1); 252 QCOMPARE(mails.size(), 1);
253 auto mail = *mails.first(); 253 auto mail = *mails.first();
254 modifiedMail = mail; 254 modifiedMail = mail;
@@ -267,7 +267,7 @@ void MailTest::testMoveMail()
267 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); 267 VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier));
268 { 268 {
269 auto job = Store::fetchAll<Mail>(Query().request<Mail::Folder>().request<Mail::Subject>().request<Mail::MimeMessage>()) 269 auto job = Store::fetchAll<Mail>(Query().request<Mail::Folder>().request<Mail::Subject>().request<Mail::MimeMessage>())
270 .syncThen<void, QList<Mail::Ptr>>([=](const QList<Mail::Ptr> &mails) { 270 .then([=](const QList<Mail::Ptr> &mails) {
271 QCOMPARE(mails.size(), 1); 271 QCOMPARE(mails.size(), 1);
272 auto mail = *mails.first(); 272 auto mail = *mails.first();
273 QCOMPARE(mail.getFolder(), folder1.identifier()); 273 QCOMPARE(mail.getFolder(), folder1.identifier());
diff --git a/tests/mailthreadtest.cpp b/tests/mailthreadtest.cpp
index 3684514..82f9331 100644
--- a/tests/mailthreadtest.cpp
+++ b/tests/mailthreadtest.cpp
@@ -179,7 +179,7 @@ void MailThreadTest::testIndexInMixedOrder()
179 /* VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); */ 179 /* VERIFYEXEC(ResourceControl::flushMessageQueue(QByteArrayList() << mResourceInstanceIdentifier)); */
180 /* { */ 180 /* { */
181 /* auto job = Store::fetchAll<Mail>(Query::RequestedProperties(QByteArrayList() << Mail::Folder::name << Mail::Subject::name)) */ 181 /* auto job = Store::fetchAll<Mail>(Query::RequestedProperties(QByteArrayList() << Mail::Folder::name << Mail::Subject::name)) */
182 /* .syncThen<void, QList<Mail::Ptr>>([=](const QList<Mail::Ptr> &mails) { */ 182 /* .then([=](const QList<Mail::Ptr> &mails) { */
183 /* QCOMPARE(mails.size(), 0); */ 183 /* QCOMPARE(mails.size(), 0); */
184 /* }); */ 184 /* }); */
185 /* VERIFYEXEC(job); */ 185 /* VERIFYEXEC(job); */
diff --git a/tests/resourcecommunicationtest.cpp b/tests/resourcecommunicationtest.cpp
index 201db53..7beafc7 100644
--- a/tests/resourcecommunicationtest.cpp
+++ b/tests/resourcecommunicationtest.cpp
@@ -51,7 +51,7 @@ private slots:
51 int errors = 0; 51 int errors = 0;
52 for (int i = 0; i < count; i++) { 52 for (int i = 0; i < count; i++) {
53 auto result = resourceAccess.sendCommand(Sink::Commands::PingCommand) 53 auto result = resourceAccess.sendCommand(Sink::Commands::PingCommand)
54 .syncThen<void>([&resourceAccess, &errors, &complete](const KAsync::Error &error) { 54 .then([&resourceAccess, &errors, &complete](const KAsync::Error &error) {
55 complete++; 55 complete++;
56 if (error) { 56 if (error) {
57 qWarning() << error.errorMessage; 57 qWarning() << error.errorMessage;
@@ -77,7 +77,7 @@ private slots:
77 int errors = 0; 77 int errors = 0;
78 for (int i = 0; i < count; i++) { 78 for (int i = 0; i < count; i++) {
79 resourceAccess.sendCommand(Sink::Commands::PingCommand) 79 resourceAccess.sendCommand(Sink::Commands::PingCommand)
80 .syncThen<void>([&resourceAccess, &errors, &complete](const KAsync::Error &error) { 80 .then([&resourceAccess, &errors, &complete](const KAsync::Error &error) {
81 complete++; 81 complete++;
82 if (error) { 82 if (error) {
83 qWarning() << error.errorMessage; 83 qWarning() << error.errorMessage;
@@ -104,7 +104,7 @@ private slots:
104 auto resourceAccess = Sink::ResourceAccessFactory::instance().getAccess(resourceIdentifier, ""); 104 auto resourceAccess = Sink::ResourceAccessFactory::instance().getAccess(resourceIdentifier, "");
105 weakRef = resourceAccess.toWeakRef(); 105 weakRef = resourceAccess.toWeakRef();
106 resourceAccess->open(); 106 resourceAccess->open();
107 resourceAccess->sendCommand(Sink::Commands::PingCommand).syncThen<void>([resourceAccess]() { qDebug() << "Ping complete"; }).exec(); 107 resourceAccess->sendCommand(Sink::Commands::PingCommand).then([resourceAccess]() { qDebug() << "Ping complete"; }).exec();
108 } 108 }
109 QVERIFY(weakRef.toStrongRef()); 109 QVERIFY(weakRef.toStrongRef());
110 QTRY_VERIFY(!weakRef.toStrongRef()); 110 QTRY_VERIFY(!weakRef.toStrongRef());