diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-01-12 11:45:15 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-01-12 11:45:15 +0100 |
commit | 7daeec83233c522980d5e477fee82045de57f77d (patch) | |
tree | 5e03d11d23c764eb03f27393fcc37c0529405e10 /tests | |
parent | af8baff21529b5bc47725da3e9e00ec81e5b6f1b (diff) | |
download | sink-7daeec83233c522980d5e477fee82045de57f77d.tar.gz sink-7daeec83233c522980d5e477fee82045de57f77d.zip |
syncThen is no longer necessary
Diffstat (limited to 'tests')
-rw-r--r-- | tests/accountstest.cpp | 8 | ||||
-rw-r--r-- | tests/clientapitest.cpp | 2 | ||||
-rw-r--r-- | tests/mailsynctest.cpp | 28 | ||||
-rw-r--r-- | tests/mailtest.cpp | 18 | ||||
-rw-r--r-- | tests/mailthreadtest.cpp | 2 | ||||
-rw-r--r-- | tests/resourcecommunicationtest.cpp | 6 |
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()); |